登录社区云,与社区用户共同成长
邀请您加入社区
记录Canal连接Kafka的一个大坑1、这个应该是canal连接mysql报的超时,不过不影响正确的结果,有知道的大佬希望给予解答2、重点是这个,巨坑,出现这个问题是因为虽然配置了canal的instance.properties中的dynamicTopic,但是canal.mg.topic没有指定,这会导致什么结果呢?会导致你配置dynaTopic的库虽然可以被kafka监听实时拉取到日志,但
1、这个应该是canal连接mysql报的超时,不过不影响正确的结果,有知道的大佬希望给予解答
2、重点是这个,巨坑,出现这个问题是因为虽然配置了canal的instance.properties中的dynamicTopic,但是canal.mg.topic没有指定,这会导致什么结果呢?会导致你配置dynaTopic的库虽然可以被kafka监听实时拉取到日志,但是导致mysql下的其他库的文件改动日志没有指向地,就会出现上图的第二个错误,一直报错,解决方法就是添加一行canal.mg.topic=XXX就可,然后重启canal就可以使用
为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。
更多推荐
openEuler系统通过shell脚本安装openGauss 5.0.0企业版
一文了解npm install -g和npm install --save-dev的关系
【FAQ】HarmonyOS SDK 闭源开放能力 —Map Kit(2)
扫一扫分享内容
所有评论(0)