一个Mysql数据库的多个debezium连接器

Question

我试图创建多个连接器相同的数据库，但得到异常

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

Answer 1

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

删除每个连接器(一个除外(，并使用新的"database.server.id"重新创建它。