[MSA]Kafka Connect - Connect Sink Example

Kafka Connect Sink - 데이터를 받는쪽

Kafka Connect Sink  등록

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

body ex)

{
    "name": "gugbab-sink-connect",

    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "connection.url": "jdbc:mysql://localhost:3306/gugbabdb",	// 연결할 DB
        "connection.user": "root",	// DB 계정
        "connection.password": {password},	// DB 비밀번호
        "auto.create": "true",
        "auto.evolve": "true",
        "delete.enabled": "false",
        "tasks.max": "1",
        "topics": "gugbab_topic_kafka_users"	// Topic의 이름과 같은 테이블 생성된다.
    }
}

 

Kafka Connect  목록 확인

• curl [Kafka-Connect-server]/connectors

 

데이터 흐름

• 데이터 변화 -> Connect Source -> Topic 데이터 쌓임 -> Connect Sink -> 데이터 추가