zergduan commented on issue #9879: URL: https://github.com/apache/rocketmq/issues/9879#issuecomment-3592302781
@john1337 多谢您的解答，如果不停删除topic和consumer group是正常的为什么备节点无法支持消费呢？ 我总结一下复现此bug的过程： 1. 版本: RocketMQ 5.3.4 OpenJDK 21 2. 2M-2S 集群，没有部署controller（不支持自动主备切换） 3. 期望在Master Broker宕机时，Slave Broker可以支持只读消费，确保宕机前堆积在Broker中的消息可以被正常消费 4. 问题：Master Broker宕机后，Slave Broker可以注册到NameServer，消费者可以连接到Slave Broker，查看Topic也变成了只读状态，但是消费者无法收到任何消息，导致堆积消息无法消费。 Broker参数配置：请参考上面楼层的内容 重现步骤： 1. 启动 NameServer，两个Master和两个Slave Broker 2. 不启动消费者，只启动生产者，开始生产消息20个（Topic TP-FTEST-Normal） 3. 查看查看集群节点，Topic路由和消息堆积信息： mqadmin clusterList <img width="3006" height="129" alt="Image" src="https://github.com/user-attachments/assets/d7d29be1-5c4b-4891-b6b4-a9b33f393961"; /> mqadmin topicRoute <img width="1635" height="729" alt="Image" src="https://github.com/user-attachments/assets/dd17ee47-bac8-4e73-98f0-6f79d46bd625"; /> mqadmin consumerProgress <img width="1911" height="585" alt="Image" src="https://github.com/user-attachments/assets/a6bb5af1-c8d8-4c9d-9fa0-069197bb5c4c"; /> <img width="2619" height="285" alt="Image" src="https://github.com/user-attachments/assets/db4e7449-e3c1-4ab5-a42e-ec4d292f6117"; /> 4. 关闭2个Master Broker，查看集群节点和Topic路由和消息堆积信息： <img width="2988" height="110" alt="Image" src="https://github.com/user-attachments/assets/00888893-f743-4d2a-aab3-1a9aeca104e2"; /> <img width="2058" height="720" alt="Image" src="https://github.com/user-attachments/assets/a141ab49-9a16-4689-87cc-0328a981ce39"; /> <img width="1989" height="578" alt="Image" src="https://github.com/user-attachments/assets/bb98db44-488a-470d-ac4c-c5f90418d3b2"; /> <img width="2652" height="288" alt="Image" src="https://github.com/user-attachments/assets/7fa787f1-5f20-4305-a3f0-2d9b251d62ff"; /> 5. 启动消费者，使用CG-FTEST-Normal消费组，试图消费堆积消息： Slave Broker的Broker.log中出现消费者成功连接到Slave Broker的日志，如下： > 2025-11-30 15:09:04 INFO HeartbeatThread_2 - new consumer connected, group: CG-FTEST-Normal CONSUME_PASSIVELY CLUSTERING channel: ClientChannelInfo [channel=[id: 0x7140b3b7, L:/10.177.96.146:22922 - R:/10.177.96.149:34538], clientId=10.177.96.149@248122#188925729096076, language=JAVA, version=477, lastUpdateTimestamp=1764486544428] 2025-11-30 15:09:04 INFO HeartbeatThread_2 - subscription changed, add new topic, group: CG-FTEST-Normal SubscriptionData [classFilterMode=false, topic=%RETRY%CG-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543855, expressionType=TAG] 2025-11-30 15:09:04 INFO HeartbeatThread_2 - subscription changed, add new topic, group: CG-FTEST-Normal SubscriptionData [classFilterMode=false, topic=TP-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543845, expressionType=TAG] 2025-11-30 15:09:04 INFO HeartbeatThread_2 - ClientManageProcessor: registerConsumer info changed, SDK address=10.177.96.149:34538, consumerData=ConsumerData [groupName=CG-FTEST-Normal, consumeType=CONSUME_PASSIVELY, messageModel=CLUSTERING, consumeFromWhere=CONSUME_FROM_FIRST_OFFSET, unitMode=false, subscriptionDataSet=[SubscriptionData [classFilterMode=false, topic=%RETRY%CG-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543855, expressionType=TAG], SubscriptionData [classFilterMode=false, topic=TP-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543845, expressionType=TAG]]] 2025-11-30 15:09:04 INFO HeartbeatThread_2 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x7140b3b7, L:/10.177.96.146:22922 - R:/10.177.96.149:34538], clientId=10.177.96.149@248122#188925729096076, language=JAVA, version=477, lastUpdateTimestamp=1764486544428] 2025-11-30 15:09:05 INFO HeartbeatThread_2 - subscription changed, group: CG-FTEST-Normal OLD: SubscriptionData [classFilterMode=false, topic=TP-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543845, expressionType=TAG] NEW: SubscriptionData [classFilterMode=false, topic=TP-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486545143, expressionType=TAG] 2025-11-30 15:09:05 INFO HeartbeatThread_1 - subscription changed, group: CG-FTEST-Normal OLD: SubscriptionData [classFilterMode=false, topic=%RETRY%CG-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486543855, expressionType=TAG] NEW: SubscriptionData [classFilterMode=false, topic=%RETRY%CG-FTEST-Normal, subString=*, tagsSet=[], codeSet=[], subVersion=1764486545154, expressionType=TAG] 2025-11-30 15:09:10 INFO brokerOutApi_thread_3 - Registering current broker to name server completed. TargetHost=10.177.96.144:19876 2025-11-30 15:09:10 INFO brokerOutApi_thread_4 - Registering current broker to name server completed. TargetHost=10.177.96.143:19876 但是消费者并没有消费到任何消息： <img width="2427" height="1128" alt="Image" src="https://github.com/user-attachments/assets/750932aa-ec78-4c5a-be26-6d46e13beb61"; /> 查看Topic路由和消息堆积信息： <img width="2640" height="1608" alt="Image" src="https://github.com/user-attachments/assets/eac24b58-615e-4f5e-8f9e-2544edd98bbd"; /> mqadmin查看消费者信息，有报错： <img width="2235" height="330" alt="Image" src="https://github.com/user-attachments/assets/b0f15df9-5002-450d-a7fe-58ec11a4a081"; /> -- 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]
