GitHub user lixiang365 edited a discussion: 5.3版本 controller模式,两个broker,有一个是不同步副本
版本5.3.0 docker 部署 三个namesrv, 每个都打开了controller 两个broker, 都打开了proxy ``` #brokerName broker-a #MasterBrokerId 1 #MasterAddr 10.99.155.247:10911 #MasterEpoch 5 #SyncStateSetEpoch 2 #SyncStateSetNums 1 InSyncReplica: ReplicaIdentity{brokerName='broker-a', brokerId=1, brokerAddress='10.99.155.247:10911', alive=true} NotInSyncReplica: ReplicaIdentity{brokerName='broker-a', brokerId=2, brokerAddress='10.99.155.248:11911', alive=true} ``` 部署完就是这样。 日志没有报错 这个问题该如何解决?目前不会自动切换 补充broker1 日志 ``` 2024-10-11 15:55:02 INFO brokerOutApi_thread_4 - Registering current broker to name server completed. TargetHost=mqnamesrv:9876 2024-10-11 15:55:02 INFO brokerOutApi_thread_2 - Registering current broker to name server completed. TargetHost=10.99.155.248:9877 2024-10-11 15:55:02 INFO brokerOutApi_thread_3 - Registering current broker to name server completed. TargetHost=10.99.155.248:9876 2024-10-11 15:55:05 INFO ReplicasManager_ScheduledService_3 - Update controller leader address to 10.99.155.248:9812 2024-10-11 15:55:05 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:55:10 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:55:15 INFO ReplicasManager_ScheduledService_1 - Update controller leader address to 10.99.155.248:9812 2024-10-11 15:55:15 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:55:20 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:55:25 INFO ReplicasManager_ScheduledService_3 - Update controller leader address to 10.99.155.248:9812 2024-10-11 15:55:25 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:55:30 INFO BrokerControllerScheduledThread1 - Dispatch task fall behind commit log 0byte ``` 补充broker2日志 ``` 2024-10-11 15:53:07 INFO brokerOutApi_thread_2 - Registering current broker to name server completed. TagetHost=10.99.155.247:9876 2024-10-11 15:53:10 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:10 INFO ReplicasManager_ScheduledService_1 - Update controller leader address to 10.99.55.248:9812 2024-10-11 15:53:13 INFO BrokerControllerScheduledThread1 - Update slave topic config from master, 10.99155.247:10911 2024-10-11 15:53:13 INFO BrokerControllerScheduledThread1 - Update slave consumer offset from master, 1099.155.247:10911 2024-10-11 15:53:13 INFO BrokerControllerScheduledThread1 - load /home/rocketmq/store/config/delayOffsetjson OK 2024-10-11 15:53:13 INFO BrokerControllerScheduledThread1 - Update slave delay offset from master, 10.99155.247:10911 2024-10-11 15:53:13 INFO BrokerControllerScheduledThread1 - Update slave Message Request Mode from maste, 10.99.155.247:10911 2024-10-11 15:53:15 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:20 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:20 INFO ReplicasManager_ScheduledService_2 - Update controller leader address to 10.99.55.248:9812 2024-10-11 15:53:25 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:25 INFO BrokerControllerScheduledThread1 - Update slave topic config from master, 10.99155.247:10911 2024-10-11 15:53:25 INFO BrokerControllerScheduledThread1 - Update slave consumer offset from master, 1099.155.247:10911 2024-10-11 15:53:25 INFO BrokerControllerScheduledThread1 - load /home/rocketmq/store/config/delayOffsetjson OK 2024-10-11 15:53:25 INFO BrokerControllerScheduledThread1 - Update slave delay offset from master, 10.99155.247:10911 2024-10-11 15:53:25 INFO BrokerControllerScheduledThread1 - Update slave Message Request Mode from maste, 10.99.155.247:10911 2024-10-11 15:53:30 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:30 INFO ReplicasManager_ScheduledService_2 - Update controller leader address to 10.99.55.248:9812 2024-10-11 15:53:35 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:37 INFO brokerOutApi_thread_2 - Registering current broker to name server completed. TagetHost=10.99.155.248:9877 2024-10-11 15:53:37 INFO brokerOutApi_thread_1 - Registering current broker to name server completed. TagetHost=10.99.155.248:9876 2024-10-11 15:53:37 INFO brokerOutApi_thread_3 - Registering current broker to name server completed. TagetHost=10.99.155.247:9876 2024-10-11 15:53:37 INFO BrokerControllerScheduledThread1 - Update slave topic config from master, 10.99155.247:10911 2024-10-11 15:53:37 INFO BrokerControllerScheduledThread1 - Update slave consumer offset from master, 1099.155.247:10911 2024-10-11 15:53:37 INFO BrokerControllerScheduledThread1 - load /home/rocketmq/store/config/delayOffsetjson OK 2024-10-11 15:53:37 INFO BrokerControllerScheduledThread1 - Update slave delay offset from master, 10.99155.247:10911 2024-10-11 15:53:37 INFO BrokerControllerScheduledThread1 - Update slave Message Request Mode from maste, 10.99.155.247:10911 2024-10-11 15:53:40 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/ac is not exist 2024-10-11 15:53:40 INFO ReplicasManager_ScheduledService_3 - Update controller leader address to 10.99.55.248:9812 ``` 关闭broker1, broker2日志 就会出现无法选举主节点 ``` 2024-10-11 15:58:55 INFO AclFileWatchService - The default acl dir /home/rocketmq/rocketmq-5.3.0/conf/acl is not exist 2024-10-11 15:58:55 ERROR BrokerControllerScheduledThread1 - syncTimerCheckPoint Exception, 10.99.155.247:10911 org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 10.99.155.247:10909 failed at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:574) at org.apache.rocketmq.broker.out.BrokerOuterAPI.getTimerCheckPoint(BrokerOuterAPI.java:786) at org.apache.rocketmq.broker.slave.SlaveSynchronize.syncTimerCheckPoint(SlaveSynchronize.java:208) at org.apache.rocketmq.broker.controller.ReplicasManager.lambda$handleSlaveSynchronize$2(ReplicasManager.java:361) 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:750) 2024-10-11 15:58:55 ERROR ReplicasManager_ScheduledService_3 - 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:1276) 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:750) ``` GitHub link: https://github.com/apache/rocketmq/discussions/8813 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org