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 [email protected].
To unsubscribe, please send an email to: [email protected]