canal deployer版本:v1.1.5
1、canal配置MQ部分
canal.mq.accessChannel = cloud canal.mq.servers = http://1570761615070884.mqrest.cn-hangzhou-internal.aliyuncs.com #canal.mq.servers = http://MQ_INST_1570761615070884_BbMlJuiA.cn-hangzhou.mq-internal.aliyuncs.com:8080 canal.mq.producerGroup = GID_PPYM_SCM_ITEM_CANAL_DAILY #canal.mq.namespace = MQ_INST_1570761615070884_BbMlJuiA canal.mq.topic = TIC_PPYM_SCM_ITEM_CANAL_DAILY
2、已事先在对应MQ中添加相应的toppic和group
3、日志报错部分: 2020-09-25 17:52:16.248 [pool-4-thread-1] ERROR c.a.o.c.c.rocketmq.producer.CanalRocketMQProducer - org.apache.rocketmq.client.exception.MQClientException: No route info for this topic, TIC_PPYM_SCM_ITEM_CANAL_DAILY For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ java.lang.RuntimeException: org.apache.rocketmq.client.exception.MQClientException: No route info for this topic, TIC_PPYM_SCM_ITEM_CANAL_DAILY For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.sendMessage(CanalRocketMQProducer.java:268) ~[na:na] at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.sendMessage(CanalRocketMQProducer.java:292) ~[na:na] at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.send(CanalRocketMQProducer.java:249) ~[na:na] at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.send(CanalRocketMQProducer.java:151) ~[na:na] at com.alibaba.otter.canal.server.CanalMQStarter.worker(CanalMQStarter.java:185) [canal.server-1.1.5-SNAPSHOT.jar:na] at com.alibaba.otter.canal.server.CanalMQStarter.access$500(CanalMQStarter.java:25) [canal.server-1.1.5-SNAPSHOT.jar:na] at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:227) [canal.server-1.1.5-SNAPSHOT.jar:na] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_241] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_241] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_241] Caused by: org.apache.rocketmq.client.exception.MQClientException: No route info for this topic, TIC_PPYM_SCM_ITEM_CANAL_DAILY For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendSelectImpl(DefaultMQProducerImpl.java:1108) ~[na:na] at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1068) ~[na:na] at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1063) ~[na:na] at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:524) ~[na:na] at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.sendMessage(CanalRocketMQProducer.java:256) ~[na:na] ... 9 common frames omitted
原提问者GitHub用户tang1987426
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。