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]

via GitHub Fri, 28 Nov 2025 14:40:51 -0800


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


   另外我发现升级到5.x后，slave broker的broker.log中会不停出现：
   
   delete topic config OK, topic: XXX
   delete subscription group OK, subscription group: XXX
   
   
   > 2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal18, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal19, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal16, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal17, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal14, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal15, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal12, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal13, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal10, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal11, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal09, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal07, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal08, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal05, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal06, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal03, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal04, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal01, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete topic 
config OK, topic: TopicConfig [topicName=TP-PTEST-Normal02, readQueueNums=4, 
writeQueueNums=4, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, 
order=false, attributes={message.type=NORMAL}]
   ......
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - Update slave 
topic config from master, 10.177.96.145:22922
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - Update slave 
consumer offset from master, 10.177.96.145:22922
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - load 
/home/paasmq/store/config/delayOffset.json OK
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - Update slave 
delay offset from master, 10.177.96.145:22922
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - 
getAllSubscriptionGroup from seq 0, max 2000, dataVersion 
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - get all 
subscription group config, totalGroupNum: 36
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=SELF_TEST_C_GROUP, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CG-FTEST-Orderly, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=true, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CID_ONSAPI_OWNER, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CG-FTEST-TXN, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CG-PRM-POC-01, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CG-PRM-POC-02, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CID_ONSAPI_PERMISSION, 
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=CID_RMQ_SYS_TRANS, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   2025-11-29 06:35:11 INFO BrokerControllerScheduledThread1 - delete 
subscription group OK, subscription 
group:SubscriptionGroupConfig{groupName=TOOLS_CONSUMER, consumeEnable=true, 
consumeFromMinEnable=true, consumeBroadcastEnable=true, 
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16, 
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null, 
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1, 
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15, 
subscriptionDataSet=null, attributes={}}
   


-- 
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]

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]

Reply via email to