canal的INVALID_TOPIC_EXCEPTION问题
·
启动canal，canal.log存在INVALID_TOPIC_EXCEPTION问题
[kafka-producer-network-thread | producer-2] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Error while fetching metadata with correlation id 7168 : {=INVALID_TOPIC_EXCEPTION}
解决方案
canal instance.properties需要打开canal.mq.topic参数
canal.mq.topic 这一项最好不要注释,可以创建一个不适用的topic配置该项
# mq config
canal.mq.topic=xxxx
原因:如果有一些不符合dynamicTopic匹配的语句的消息会发送到该topic而避免报错 INVALID_TOPIC_EXCEPTION
旨在为数千万中国开发者提供一个无缝且高效的云端环境，以支持学习、使用和贡献开源项目。
更多推荐
0
0- 0
已为社区贡献1条内容
所有评论(0)