一个 Mysql DB 的多个 debezium 连接器答案

【问题标题】：Multiple debezium connector for one Mysql DB一个 Mysql DB 的多个 debezium 连接器
【发布时间】：2020-12-10 21:46:38
【问题描述】：

我正在尝试创建多个连接器相同的数据库，但出现异常

org.apache.kafka.connect.errors.ConnectException: 一个与这个slave具有相同server_uuid/server_id的slave已经连接到master；第一个事件'mysql-bin.000004'在1088，最后一个事件从'./mysql-bin.000004'读取在1310，最后一个字节从'./mysql-bin.000004'在1310读取。错误代码： 1236; SQLSTATE: HY000.\n\tat io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)

【问题讨论】：

标签： mysql apache-kafka-connect debezium

【解决方案1】：

在每个连接器配置中，“database.server.id”字段必须是唯一的。

删除每个连接器（除了一个）并使用新的“database.server.id”重新创建它。

【讨论】：

debezium.io/documentation/reference/connectors/mysql.html 表 16 server-id 参数：“对于 MySQL 集群中的每个服务器和复制客户端，server-id 的值必须是唯一的。在 MySQL 连接器设置期间，Debezium 分配一个唯一的连接器的服务器 ID。”。