学习用kafka Debezium来捕捉mysql变化
在注册完连接器之后测试一下:
创建kafka消费者:
向mysql插入数据
但是消费者没有任何反应,kafka connect没有报错。
查看kafka tools
浏览器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://b23.tv/7mvUCC7