opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix topicRouteMap maintain error relationship

Browse Source
This commit is contained in:
huitong
2022-01-04 11:40:44 +08:00
committed by zhangyang
parent 9f9b109172
commit 6ebb4e40d4
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
+3 -1
View File
@@ -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()) {