debezium connector 설정은 다음과 같다. 이 정보를 debezium connector에 올리면 DB에서 데이터를 덤프 및 CDC를 진행한다.
{
“name”: “google_debezium_connector_shopping_orders”,
“config”: {
“connector.class”: “io.debezium.connector.mysql.MySqlConnector”,
“tasks.max”: “1”,
“database.hostname”: “mysql.google.com”,
“database.port”: “3306”,
“database.user”: “debezium”,
“database.password”: “google_debezium”,
“database.server.id”: “18405”,
“database.server.name”: “google-shopping”,
“database.whitelist”: “shopping”,
“table.whitelist”: “shopping.demo_orders”,
“database.history.kafka.bootstrap.servers”: “kafka:29092”,
“database.history.kafka.topic”: “schema_changes_shopping_orders”
}
}
이때 어느 kafak의 어느 topic에 CDC 데이터가 저장될까??
kafka connector 에 debezium을 사용할 때
serverName(database.server.name).databaseName.tableName이 합쳐진 카프카 토픽에 value가 저장된다.
google-shopping.shopping.demo_orders
database.history.kafka.topic 값을 읽다가 알게 되었다. 사실 문서에 다 있다.
