GitHub user drivebyer added a comment to the discussion: 部署 3 节点 controller ,broker 状态 alive 显示为 false
感谢回复。 刚才我又使用同样的步骤测试了一下,出现了不同的现象。 ### controller ``` [root@master0 ~]# kubectl -n mcamel-system exec -it controller-1 -- ./mqadmin getSyncStateSet -a 127.0.0.1:9878 -c broker -b broker-0 #brokerName broker-0 #MasterBrokerId null #MasterAddr null #MasterEpoch 2 #SyncStateSetEpoch 1 #SyncStateSetNums 1 InSyncReplica: ReplicaIdentity{brokerName='broker-0', brokerId=1, brokerAddress='192.168.137.114:10911', alive=false} NotInSyncReplica: ReplicaIdentity{brokerName='broker-0', brokerId=2, brokerAddress='192.168.84.226:10911', alive=true} ``` nameserver: ``` [root@master0 ~]# kubectl -n mcamel-system exec -it name-service-0 -- ./mqadmin clusterList -n 127.0.0.1:9876 #Cluster Name #Broker Name #BID #Addr #Version #InTPS(LOAD) #OutTPS(LOAD) #Timer(Progress) #PCWait(ms) #Hour #SPACE #ACTIVATED broker broker-0 0 192.168.137.114:10911 V5_1_4 0.00(0,0ms) 0.00(0,0ms) 0-0(0.0w, 0.0, 0.0) 0 474795.68 0.6800 true ``` ### broker(192.168.84.226) 的日志: ``` 2024-03-01 11:41:17 WARN ReplicasManager_ExecutorService_1 - Failed to start replicasManager, retry times:22, current state:REGISTER_TO_CONTROLLER_DONE, try it again 2024-03-01 11:41:17 ERROR ReplicasManager_ExecutorService_1 - Failed to try elect org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2012 DESC: Failed to elect a new master For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ at org.apache.rocketmq.broker.out.BrokerOuterAPI.brokerElect(BrokerOuterAPI.java:1237) at org.apache.rocketmq.broker.controller.ReplicasManager.brokerElect(ReplicasManager.java:378) at org.apache.rocketmq.broker.controller.ReplicasManager.startBasicService(ReplicasManager.java:200) at org.apache.rocketmq.broker.controller.ReplicasManager.lambda$start$0(ReplicasManager.java:156) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) ``` broker (192.168.137.114) 的日志: ``` 2024-03-01 11:44:49 INFO ReplicasManager_ScheduledService_1 - Update controller leader address to controller-1.controller-svc-headless:9878 2024-03-01 11:44:50 ERROR ReplicasManager_ScheduledService_2 - Failed to try elect org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2012 DESC: Failed to elect a new master For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ at org.apache.rocketmq.broker.out.BrokerOuterAPI.brokerElect(BrokerOuterAPI.java:1237) at org.apache.rocketmq.broker.controller.ReplicasManager.brokerElect(ReplicasManager.java:378) at org.apache.rocketmq.broker.controller.ReplicasManager.lambda$schedulingSyncBrokerMetadata$3(ReplicasManager.java:663) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) ``` GitHub link: https://github.com/apache/rocketmq/discussions/7877#discussioncomment-8638024 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org