Re: [I] [Bug] In 5.3.3 and 5.3.4, within the master-slave Broker cluster, when the master Broker is down, can not consume the backlog of messages from the standby Broker. [rocketmq]

Fri, 28 Nov 2025 04:19:45 -0800 


zergduan commented on issue #9879:
URL: https://github.com/apache/rocketmq/issues/9879#issuecomment-3589122815

   以下是我2M-2S集群，NameServer和Broker的启动参数：
   
   NameServer：
   > listenPort=19876
   orderMessageEnable=true
   supportActingMaster=true
   metricsExporterType=PROM
   
   
   Broker-a Master
   > listenPort=22922
   namesrvAddr=10.177.96.143:19876;10.177.96.144:19876
   brokerIP1=10.177.96.145
   brokerName=POC-Broker-a
   brokerClusterName=POC-Cluster
   brokerId=0
   enableSlaveActingMaster=true
   metricsExporterType=PROM
   deleteWhen=04
   fileReservedTime=24
   brokerRole=ASYNC_MASTER
   flushDiskType=SYNC_FLUSH
   autoCreateTopicEnable=false
   autoCreateSubscriptionGroup=false
   traceTopicEnable=true
   authenticationEnabled = true
   authenticationProvider = 
org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
   initAuthenticationUser = {"username":"rocketmq","password":"XXX$XXX"}
   innerClientAuthenticationCredentials = 
{"accessKey":"rocketmq","secretKey":"XXX$XXX"}
   authenticationMetadataProvider = 
org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
   authorizationEnabled = true
   authorizationProvider = 
org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
   authorizationMetadataProvider = 
org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
   
   
   Broker-a Slave
   > listenPort=22922
   namesrvAddr=10.177.96.143:19876;10.177.96.144:19876
   brokerIP1=10.177.96.146
   brokerName=POC-Broker-a
   brokerClusterName=POC-Cluster
   brokerId=1
   enableSlaveActingMaster=true
   metricsExporterType=PROM
   deleteWhen=04
   fileReservedTime=24
   brokerRole=SLAVE
   flushDiskType=SYNC_FLUSH
   autoCreateTopicEnable=false
   autoCreateSubscriptionGroup=false
   traceTopicEnable=true
   authenticationEnabled = true
   authenticationProvider = 
org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
   initAuthenticationUser = {"username":"rocketmq","password":"XXX$XXX"}
   innerClientAuthenticationCredentials = 
{"accessKey":"rocketmq","secretKey":"XXX$XXX"}
   authenticationMetadataProvider = 
org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
   authorizationEnabled = true
   authorizationProvider = 
org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
   authorizationMetadataProvider = 
org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
   
   
   Broker-b Master
   
   > listenPort=22922
   namesrvAddr=10.177.96.143:19876;10.177.96.144:19876
   brokerIP1=10.177.96.147
   brokerName=POC-Broker-b
   brokerClusterName=POC-Cluster
   brokerId=0
   enableSlaveActingMaster=true
   metricsExporterType=PROM
   deleteWhen=04
   fileReservedTime=24
   brokerRole=ASYNC_MASTER
   flushDiskType=SYNC_FLUSH
   autoCreateTopicEnable=false
   autoCreateSubscriptionGroup=false
   traceTopicEnable=true
   authenticationEnabled = true
   authenticationProvider = 
org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
   initAuthenticationUser = {"username":"rocketmq","password":"XXX$XXX"}
   innerClientAuthenticationCredentials = 
{"accessKey":"rocketmq","secretKey":"XXX$XXX"}
   authenticationMetadataProvider = 
org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
   authorizationEnabled = true
   authorizationProvider = 
org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
   authorizationMetadataProvider = 
org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
   
   Broker-b Slave
   
   > listenPort=22922
   namesrvAddr=10.177.96.143:19876;10.177.96.144:19876
   brokerIP1=10.177.96.148
   brokerName=POC-Broker-b
   brokerClusterName=POC-Cluster
   brokerId=1
   enableSlaveActingMaster=true
   metricsExporterType=PROM
   deleteWhen=04
   fileReservedTime=24
   brokerRole=SLAVE
   flushDiskType=SYNC_FLUSH
   autoCreateTopicEnable=false
   autoCreateSubscriptionGroup=false
   traceTopicEnable=true
   authenticationEnabled = true
   authenticationProvider = 
org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
   initAuthenticationUser = {"username":"rocketmq","password":"XXX$XXX"}
   innerClientAuthenticationCredentials = 
{"accessKey":"rocketmq","secretKey":"XXX$XXX"}
   authenticationMetadataProvider = 
org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
   authorizationEnabled = true
   authorizationProvider = 
org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
   authorizationMetadataProvider = 
org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to