mysql - 一个 Mysql DB 的多个 debezium 连接器

Question

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

org.apache.kafka.connect.errors.ConnectException：与该从属具有相同 server_uuid/server_id 的从属已连接到主控；第一个事件'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)

标签： mysqlapache-kafka-connectdebezium

Answer 1

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

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