From dfb625377b85afae67f9e17d6e7a263a11be9aea Mon Sep 17 00:00:00 2001 From: 17hao Date: Wed, 3 Feb 2021 22:30:38 +0800 Subject: [PATCH] Using existing topic name constant --- .../manager/service/service/impl/TopicManagerServiceImpl.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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 96913e50..fc5f678d 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,8 +50,6 @@ 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; @@ -277,7 +275,7 @@ public class TopicManagerServiceImpl implements TopicManagerService { } Map> topicMap = new HashMap<>(appList.size()); for (TopicDO topicDO: topicList) { - if (topicDO.getTopicName().equals(CONSUMER_OFFSETS_TOPIC)) { + if (topicDO.getTopicName().equals(KafkaConstant.COORDINATOR_TOPIC_NAME)) { continue; } Map subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>());