카프카 커넥터 생성

커넥터 생성

kubectl exec -it connect-0 -n debezium -- curl -X POST 10.44.0.5:8083/connectors/ -H "Content-Type:application/json"  -d '{ "name": "conn5", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "tasks.max": "1", "database.hostname": "35.78.222.244", "database.port": "3306", "database.user": "test", "database.password": "123", "database.server.id": "184058", "database.server.name": "dbserver", "database.include.list": "test", "schema.history.internal.kafka.bootstrap.servers": "kafka-broker-0.kafka-service.default.svc.cluster.local:9092 ,kafka-broker-1.kafka-service.default.svc.cluster.local:9092,kafka-broker-2.kafka-service.default.svc.cluster.local:9092","topic.prefix": "test_", "schema.history.internal.kafka.topic": "debezium" } }''

이렇게 rest 요청을 전송한다.

생성 확인

curl -X GET podIP:8083/connectors

상태 확인

curl -X GET podIP:8083/connectors/connectorname/status

토픽 확인

정상적으로 받아진다.