[ISSUE #7951] return the full statsInfo when read and write queues ar…

…e inconsistent Co-authored-by: dengzhiwen1 <[email protected]>
apache · Mar 24, 2024 · 402d31a · 402d31a
1 parent 27d8375
commit 402d31a
Showing 1 changed file with 3 additions and 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
@@ -1551,7 +1551,9 @@ private RemotingCommand getTopicStatsInfo(ChannelHandlerContext ctx,
         }
 
         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());