当我通过kakfa-connect的REST检查debezium连接器的状态时,我看到连接器的错误消息:
org.apache.kafka.connect.errors.ConnectException:从服务器正在使用更改母版连接到MASTER_AUTO_POSITION = 1,但是主程序清除了包含从服务器所需的GTID的二进制日志。错误代码: 1236;SQLSTATE: HY000.\n\tat io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)\n\tat io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:197)\n\tat io.debezium.connector.mysql.BinlogReader$ReaderThreadLifecycleListener.onCommunicationFailure(BinlogReader.java:997)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:950)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)\n\tat java.lang.Thread.run(Thread.java:748)\n由: com.github.shyiko.mysql.binlog.network.ServerException:奴隶使用更改主连接到MASTER_AUTO_POSITION = 1,但是主程序清除了包含从服务器所需的GTID的二进制日志。\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:914)\n\t...多3名\n
这是我如何配置debezium连接器的问题还是MySQL的问题?疯狂的是,即使我尝试将选项snapshot.mode设置为never,这个错误仍然会被抛出!根据文档,当snapshot.mode设置为never或when_needed时,它不应该要求GTID,所以我对正在发生的事情非常困惑。
发布于 2021-04-21 11:01:09
问题是Debezium可能已经关闭了一段时间,并且它没有看到的一些事务在服务器上不再可用。
https://stackoverflow.com/questions/67166834
复制相似问题