学习用kafka Debezium来捕捉mysql变化
在注册完连接器之后测试一下:
创建kafka消费者:
向mysql插入数据
但是消费者没有任何反应,kafka connect没有报错。
查看kafka tools
可以看到连接器启动之前mysql变化的数据,但是刚刚mysql变化没有捕捉到。
浏览器http:local host:8083/connectors/mysql connector/status 查看连接器运行状态是running运行正常
这没有报错,我不知道问题出在哪里?