Kafka Connect 与 Debezium MySQL CDC 实战

Kafka Connect 与 Debezium MySQL CDC 实战前置条件MySQL 启用 binlog：`log_bin`，`binlog_format=ROW`为连接器账户授予 `REPLICATION SLAVE` 与 `REPLICATION CLIENT`连接器配置（HTTP）POST /connectors

Content-Type: application/json

{

"name": "debezium-mysql",

"config": {

"connector.class": "io.debezium.connector.mysql.MySqlConnector",

"database.hostname": "mysql",

"database.port": "3306",

"database.user": "debezium",

"database.password": "secret",

"database.server.id": "184054",

"database.server.name": "db",

"database.include.list": "app",

"table.include.list": "app.items",

"include.schema.changes": "false",

"decimal.handling.mode": "double"

}

}

主题命名变更主题：`db.app.items`验证消费 `db.app.items` 主题，观察 `op` 字段的 `c/u/d` 变更类型总结Debezium 提供稳定的 CDC 能力，配合 Kafka Connect 便于扩展增量数据处理链路。