canal全量同步失败

0sgqnhkj  于 4个月前  发布在  其他
关注(0)|答案(1)|浏览(127)

canal 全量同步 mysql 某些表的数据到 rocketmq,有的表可以同步进 rocketmq,有的表不行,而且不管行或者不行都会报下面的报错:

Caused by: org.apache.rocketmq.client.exception.MQClientException: The specified topic is blank
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.Validators.checkTopic(Validators.java:107) ~[na:na]
at org.apache.rocketmq.client.Validators.checkMessage(Validators.java:87) ~[na:na]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendSelectImpl(DefaultMQProducerImpl.java:1104) ~[na:na]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1092) ~[na:na]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1087) ~[na:na]
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:508) ~[na:na]
at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.sendMessage(CanalRocketMQProducer.java:287) ~[na:na]
... 8 common frames omitted

其他一点报错没有,各位大神有遇到跟我一样情况的么

wgxvkvu9

wgxvkvu91#

有的,也碰到了,说是canal.mq.topic不能为空,配一个默认值

相关问题