From 6ebb4e40d4943679d5e37dbc96919e8cfc5808f5 Mon Sep 17 00:00:00 2001
From: huitong <yibin.xyb@alibaba-inc.com>
Date: Fri, 31 Dec 2021 14:36:41 +0800
Subject: [PATCH] fix topicRouteMap maintain error relationship

---
 .../apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
index 80999c2424..1e835f79f7 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
@@ -484,7 +484,9 @@ public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner {
         Map<String, Integer> topicRouteMap = new HashMap<String, Integer>();
         for (BrokerData bd : topicRouteData.getBrokerDatas()) {
             for (QueueData queueData : topicRouteData.getQueueDatas()) {
-                topicRouteMap.put(bd.selectBrokerAddr(), queueData.getReadQueueNums());
+                if (StringUtils.equals(queueData.getBrokerName(), bd.getBrokerName())) {
+                    topicRouteMap.put(bd.selectBrokerAddr(), queueData.getReadQueueNums());
+                }
             }
         }
         for (BrokerData bd : topicRouteData.getBrokerDatas()) {