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

关于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日