[MSA]Kafka Connect - Connect Source Example

Kafka Connect Source - 데이터를 보내는 쪽

 

Kafka Connect Source  등록

•  curl -X POST -d @- [kafka-Connect-server]/connectors --header "content-Type:applicatin/json"

body ex)

{
    "name": "gugbab-source-connect",    // 커넥트 이름
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "connection.url": "jdbc:mysql://localhost:3306/gugbabdb",	// 연결할 DB
        "connection.user": "root",	// DB 계정
        "connection.password": {password},	// DB 비밀번호
        "mode": "incrementing",	// Id 증가 방식
        "incrementing.column.name": "id",	// 어떤 컬럼 증가시킬지
        "table.whitelist": "kafka_users",		// table 명
        "topic.prefix": "gugbab_topic_",
        "tasks.max": "1"
    }
}

 

Kafka Connect Source  목록 확인

• curl [Kafka-Connect-server]/connectors

 

Kafka Connect  상세 확인

• curl [Kafka-Connect-server]/connectors/{connector name}/status

 

Kafka Topic 추가 확인

• kafka connect에 등록된 정보가 변경되면 topic이 생성된다.