时间戳

首页 > 解决方案 > 由于错误代码 1236，无法启动 debezium MySQL 连接器

mysql - 由于错误代码 1236，无法启动 debezium MySQL 连接器

问题描述

当我通过 kakfa-connect 的 REST API 检查我的 debezium 连接器的状态时，我看到连接器的以下错误消息：

org.apache.kafka.connect.errors.ConnectException：从站正在使用 CHANGE MASTER TO 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.

这是我如何配置我的 debezium 连接器的问题还是 MySQL 的问题？疯狂的是，即使我尝试将选项设置snapshot.mode为never并且仍然抛出此错误！根据文档，何时snapshot.mode设置为never或者when_needed它不应该需要 GTID，所以我对正在发生的事情感到非常困惑

标签： mysqlapache-kafkaapache-kafka-connectdebezium

解决方案

问题是 Debezium 可能已经关闭了一段时间，并且它没有看到的一些事务在服务器上不再可用。

推荐阅读