[kafka] kafka-connect Rest API 호출하기

kafka-connect 의 서버 주소: localhost:8083

 

 

[GET] /connectors : 커넥터 목록 조회

[GET] /connectors/{connector_name} : 특정 커넥터의 이름으로 상세 조회

[GET] /connectors/{connector_name}/status : 커넥터의 상태 조회

[GET] /connector-plugins : 카프카 커넥터 내부에 설치된 플러그인 조회

 

[POST] /connectors : 커넥터 생성 (Body에 JSON 형식으로 데이터 입력)

{
    "name": "my-source-connect",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "connection.url": "jdbc:mariadb://localhost:3306/mydb",
        "connection.user": "root",
        "connection.password": "1234",
        "mode": "incrementing",
        "incrementing.column.name": "id",
        "table.whitelist": "mydb.users",
        "topic.prefix": "my_topic_",
        "tasks.max": "1"
    }
}

 

- conector.class : Connector를 생성하기 위해서 필요한 클래스를 작성한다. 

- conector.url : 데이터베이스 접근을 위한 주소를 설정한다.

- conector.user : 데이터베이스 접속을 위한 id 설정한다.

- conector.password : 데이터베이스 접속을 위한 password를 설정한다.

- mode: 테이블의 변경사항을 어떤 방식으로 가져올지 설정한다.

   - bulk : 테이블에 변경사항이 있을 경우 전체 테이블의 내용을 모두 복사

   - incrementing : incrementing.column 의 컬럼값에서 새로 추가된 row의 데이터만 poll

- table.ahitelist : 데이터를 poll할 테이블 (여러개인 경우 '콤마(,)'를 이용함)

- topic.prefix : topic 생성시 이름앞에 붙일 접두어 (topic이름은 prefix + 테이블명이됨)

- tasks.max : 작업자의 최대 수

 

[DELETE] /connectors/{connector_name} : 커넥터의 이름으로 삭제