[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
