From 63d291cb470a54d9b74c291711b2973964697849 Mon Sep 17 00:00:00 2001 From: 17hao Date: Wed, 3 Feb 2021 15:50:33 +0800 Subject: [PATCH] Remove __consumer_offsets from topic list --- .../manager/service/service/impl/TopicManagerServiceImpl.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java index 0b42d068..9e381587 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java @@ -50,6 +50,8 @@ import java.util.stream.Collectors; public class TopicManagerServiceImpl implements TopicManagerService { private static final Logger LOGGER = LoggerFactory.getLogger(TopicManagerServiceImpl.class); + private static final String CONSUMER_OFFSETS_TOPIC = "__consumer_offsets"; + @Autowired private TopicDao topicDao; @@ -275,6 +277,8 @@ public class TopicManagerServiceImpl implements TopicManagerService { } Map> topicMap = new HashMap<>(appList.size()); for (TopicDO topicDO: topicList) { + if (topicDO.getTopicName().equals(CONSUMER_OFFSETS_TOPIC)) + continue; Map subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>()); subTopicMap.put(topicDO.getTopicName(), topicDO); topicMap.put(topicDO.getClusterId(), subTopicMap);