Kafka Series [Part10]: MySQL Connector

Table of Contents

./kafka/bin/zookeeper-server-start.sh [-daemon] ./kafka/config/zookeeper.properties
./kafka/bin/kafka-server-start.sh ./kafka/config/server.properties
./kafka/bin/connect-distributed.sh ./kafka/config/connect-distributed.properties

# 등록 가능한 커넥터 플러그인 목록
curl -X GET http://localhost:8083/connector-plugins

# connect-distributed.properties

# 이렇게 추가하면 FileStreamSinkConnector, FileStreamSourceConnector 커넥터 클래스가 추가됨 (아래와 같은 경로가 없음에도 불구하고.. 그래서 이해가 안됨)
plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors

# 현재 등록된 커넥터 목록
curl -X GET http://localhost:8083/connectors

# FileStreamSinkConnector 커넥터 등록 (토픽 메세지를 파일에 쓴다)
curl -X POST http://localhost:8083/connectors -H 'Content-Type: application/json' -d '{ "name": "file-sink-test", "config": { "topics": "test", "connector.class": "org.apache.kafka.connect.file.FileStreamSinkConnector", "tasks.max": 1, "file": "./connect-test.txt"}}'

# 커넥터 상태 조회
curl -X GET http://localhost:8083/connectors/file-sink-test/status

요청 메서드	경로	설명
GET	/connector-plugins	사용 가능한 커넥터 플러그인 목록
GET	/	커넥트 정보
GET	/connectors	커넥터 목록
POST	/connectors	커넥터 등록
GET	/connectors/<커넥터 이름="">	커넥터 정보 확인
GET	/connectors/<커넥터 이름="">/config	커넥터 설정값 확인
PUT	/connectors/<커넥터 이름="">/config	커넥터 설정값 변경
GET	/connectors/<커넥터 이름="">/status	커넥터 상태 확인
POST	/connectors/<커넥터 이름="">/restart	커넥터 재실행
DELETE	/connectors/<커넥터 이름="">	커넥터 삭제