小龙人758 2022-10-26 12:40 采纳率: 88%
浏览 72
已结题

关于kafka Debezium捕获mysql问题

学习用kafka Debezium来捕捉mysql变化

在注册完连接器之后测试一下：

创建kafka消费者：

img

向mysql插入数据

img

但是消费者没有任何反应，kafka connect没有报错。

查看kafka tools

img


可以看到连接器启动之前mysql变化的数据，但是刚刚mysql变化没有捕捉到。

浏览器http：local host：8083/connectors/mysql connector/status 查看连接器运行状态是running运行正常

这没有报错，我不知道问题出在哪里？

  • 写回答

4条回答 默认 最新

  • 三千烦恼丝xzh 2022-10-26 14:25
    关注

    MySQL binlog状态，连接器startup.model选项使用那种形式，最后不行在看debezium的日志

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题？

问题事件

  • 系统已结题 11月3日
  • 已采纳回答 10月26日
  • 创建了问题 10月26日