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

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

悬赏问题

  • ¥15 delta降尺度计算的一些细节,有偿
  • ¥15 Arduino红外遥控代码有问题
  • ¥15 数值计算离散正交多项式
  • ¥30 数值计算均差系数编程
  • ¥15 redis-full-check比较 两个集群的数据出错
  • ¥15 Matlab编程问题
  • ¥15 训练的多模态特征融合模型准确度很低怎么办
  • ¥15 kylin启动报错log4j类冲突
  • ¥15 超声波模块测距控制点灯,灯的闪烁很不稳定,经过调试发现测的距离偏大
  • ¥15 import arcpy出现importing _arcgisscripting 找不到相关程序