关于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运行正常

这没有报错,我不知道问题出在哪里?

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

提供参考实例,期望对你有所帮助:https://cloud.tencent.com/developer/article/1406851

你得把connector的配置贴出来,才好帮你定位问题。

看我debezium专栏内容吧,内容很详细,能收获很多:
https://blog.csdn.net/zhengzaifeidelushang/category_11240845.html?spm=1001.2014.3001.5482

https://blog.csdn.net/zhengzaifeidelushang/article/details/119152017?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522166677419616782391828301%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=166677419616782391828301&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-22-119152017-null-null.article_score_rank_blog&utm_term=mysql&spm=1018.2226.3001.4450

博主参考下下面链接
https://b23.tv/7mvUCC7