diff --git a/src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java b/src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java index 2219782..a91cbeb 100644 --- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java +++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java @@ -103,6 +103,8 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum private final List cacheConsumeInfoList = Collections.synchronizedList(new ArrayList<>()); + private final HashMap> consumerGroupMap = Maps.newHashMap(); + @Override public void afterPropertiesSet() { Runtime runtime = Runtime.getRuntime(); @@ -174,7 +176,6 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum public void makeGroupListCache() { - HashMap> consumerGroupMap = Maps.newHashMap(); SubscriptionGroupWrapper subscriptionGroupWrapper = null; try { ClusterInfo clusterInfo = clusterInfoService.get(); @@ -530,6 +531,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum GroupConsumeInfo updatedInfo = queryGroup(consumerGroup, ""); updatedInfo.setUpdateTime(new Date()); updatedInfo.setGroup(consumerGroup); + updatedInfo.setAddress(consumerGroupMap.get(consumerGroup)); cacheConsumeInfoList.set(i, updatedInfo); return updatedInfo; } @@ -541,6 +543,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum @Override public List refreshAllGroup(String address) { cacheConsumeInfoList.clear(); + consumerGroupMap.clear(); return queryGroupList(false, address); } } diff --git a/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java b/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java index 14c00a2..b017683 100644 --- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java +++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java @@ -91,8 +91,6 @@ public class TopicServiceImpl extends AbstractCommonService implements TopicServ @Autowired private RMQConfigure configure; - private final ConcurrentMap topicConfigCache = new ConcurrentHashMap<>(); - @Override public TopicList fetchAllTopicList(boolean skipSysProcess, boolean skipRetryAndDlq) { try {