Kafka connect 로 Source connect, Sink connect 생성 및 테스트 해보기


Kafka connect 로 Source connect, Sink connect 생성 및 테스트 해보기

kafka connect 서버 실행 zookeeper 서버와 kafka 서버를 실행시키고 kafka connect 서버를 실행시키면 Topic 에 connect-configs, connect-offsets, connect-status 가 추가된 것을 볼 수 있다. kafka connect 를 Rest API 로 생성 및 삭제 가능 kafka connect 서버 주소는 로컬에서 localhost:8083 이다 [GET] /connectors – 모든 connector 를 조회한다. [GET] /connectors/{name} – {name}을 갖는 connector 의 정보를 조회한다. [POST] /connectors – 커넥터를 생성한다, Body쪽에는 JSON Object 타입의 커넥터 config정보가 있어야한다. [GET] /connectors/{name}/status – 이 connector 가 running인지, failed인지 paused 인지 현재..........



원문링크 : Kafka connect 로 Source connect, Sink connect 생성 및 테스트 해보기