canal.mq.servers = name-server-service-1-middleware:9876,name-server-service-2-middleware:9876
配置成这样 逗号分隔 instance提示MQ链接错误
ava.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [name-server-service-1.otc-middleware:9876,name-server-service-2.otc-middleware:9876] failed
at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:74) ~[canal.common-1.1.5.jar:na]
at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.send(CanalRocketMQProducer.java:271) ~[na:na]
at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.send(CanalRocketMQProducer.java:173) ~[na:na]
at com.alibaba.otter.canal.server.CanalMQStarter.worker(CanalMQStarter.java:181) [canal.server-1.1.5.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter.access$100(CanalMQStarter.java:25) [canal.server-1.1.5.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:223) [canal.server-1.1.5.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_181]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [name-server-service-1-middleware:9876,name-server-service-2-middleware:9876] failed
at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_181]
at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_181]
at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:72) ~[canal.common-1.1.5.jar:na]
... 8 common frames omitted
只配一个就可以
3条答案
按热度按时间wkftcu5l1#
同样的情况,有解决嘛
rur96b6h2#
name-server-service-1-middleware:9876;name-server-service-2-middleware:9876
用分号分隔 而不是 逗号,
没有十年老血栓真想不到这帮人脑子里面是什么,也没个提示,通常不都是逗号么
lpwwtiir3#
老哥,是instance里加canal.mq.servers的配置吗,不用改server里的host嘛