"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 便于扩展增量数据处理链路。