Skip to content

Commit

Permalink
[ISSUE apache#7951] return the full statsInfo when read and write que…
Browse files Browse the repository at this point in the history
…ues are inconsistent

Co-authored-by: dengzhiwen1 <[email protected]>
  • Loading branch information
cserwen and dengzhiwen1 authored Mar 24, 2024
1 parent 27d8375 commit 402d31a
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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());
Expand Down

0 comments on commit 402d31a

Please sign in to comment.