我使用 Debezium 作为 CDC 工具来从 MySql 流式传输数据。将 Debezium MySQL 连接器安装到 Confluence OSS 集群后,我尝试将 MySQL bin_log 更改捕获到 Kafka 主题中。当我创建连接器时,在拍摄数据库快照后,我留下了一系列连续的错误。
我检查了 MySql bin_log 是否已打开,并尝试使用不同的序列化程序重新启动架构注册表和连接器。但我遇到了同样的错误。
错误日志显示:
[2019-06-21 13:56:14,885] INFO Step 8: - Completed scanning a total of 955 rows from table 'mydb.test' after 00:00:00.086 (io.debezium.connector.mysql.SnapshotReader:565)
[2019-06-21 13:56:14,886] INFO Step 8: scanned 1758 rows in 2 tables in 00:00:00.383 (io.debezium.connector.mysql.SnapshotReader:601)
[2019-06-21 13:56:14,886] INFO Step 9: committing transaction (io.debezium.connector.mysql.SnapshotReader:635)
[2019-06-21 13:56:14,887] INFO Completed snapshot in 00:00:01.055 (io.debezium.connector.mysql.SnapshotReader:701)
[2019-06-21 13:56:14,965] WARN [Producer clientId=producer-5] Error while fetching …Run Code Online (Sandbox Code Playgroud)