记录Canal连接Kafka的一个大坑

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-lSe4aosg-1616732880242)(C:%5CUsers%5Cxiaoyoupei%5CAppData%5CRoaming%5CTypora%5Ctypora-user-images%5Cimage-20210326122233386.png)]

1、这个应该是canal连接mysql报的超时,不过不影响正确的结果,有知道的大佬希望给予解答

2、重点是这个,巨坑,出现这个问题是因为虽然配置了canal的instance.properties中的dynamicTopic,但是canal.mg.topic没有指定,这会导致什么结果呢?会导致你配置dynaTopic的库虽然可以被kafka监听实时拉取到日志,但是导致mysql下的其他库的文件改动日志没有指向地,就会出现上图的第二个错误,一直报错,解决方法就是添加一行canal.mg.topic=XXX就可,然后重启canal就可以使用

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-dthXnLoZ-1616732880245)(C:%5CUsers%5Cxiaoyoupei%5CAppData%5CRoaming%5CTypora%5Ctypora-user-images%5Cimage-20210326122457843.png)]

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐