canal.mq.servers集群地址配置方式

6psbrbz9  于 4个月前  发布在  其他
关注(0)|答案(3)|浏览(116)

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

只配一个就可以

wkftcu5l

wkftcu5l1#

同样的情况,有解决嘛

rur96b6h

rur96b6h2#

name-server-service-1-middleware:9876;name-server-service-2-middleware:9876

用分号分隔 而不是 逗号,
没有十年老血栓真想不到这帮人脑子里面是什么,也没个提示,通常不都是逗号么

lpwwtiir

lpwwtiir3#

老哥,是instance里加canal.mq.servers的配置吗,不用改server里的host嘛

相关问题