alibaba / canal

阿里巴巴 MySQL binlog 增量订阅&消费组件
Apache License 2.0
28.44k stars 7.6k forks source link

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

Open farsunset opened 2 years ago

farsunset commented 2 years ago

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

只配一个就可以

18068375397 commented 1 year ago

同样的情况,有解决嘛

farsunset commented 1 year ago

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

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

18068375397 commented 1 year ago

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