(rocketmq) branch develop updated: [ISSUE #7951] return the full statsInfo when read and write queues are inconsistent

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 402d31a1b8 [ISSUE #7951] return the full statsInfo when read and write 
queues are inconsistent
402d31a1b8 is described below

commit 402d31a1b88bf209f569f6c227048a01311defd3
Author: cserwen <cser...@apache.org>
AuthorDate: Sun Mar 24 18:58:45 2024 +0800

    [ISSUE #7951] return the full statsInfo when read and write queues are 
inconsistent
    
    Co-authored-by: dengzhiwen1 <dengzhiw...@xiaomi.com>
---
 .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index d0a03a93bf..362caf9ca6 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -1551,7 +1551,9 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
         }
 
         TopicStatsTable topicStatsTable = new TopicStatsTable();
-        for (int i = 0; i < topicConfig.getWriteQueueNums(); i++) {
+
+        int maxQueueNums = Math.max(topicConfig.getWriteQueueNums(), 
topicConfig.getReadQueueNums());
+        for (int i = 0; i < maxQueueNums; i++) {
             MessageQueue mq = new MessageQueue();
             mq.setTopic(topic);
             
mq.setBrokerName(this.brokerController.getBrokerConfig().getBrokerName());