8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-09 16:32:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Using existing topic name constant

Browse Source
This commit is contained in:
17hao
2021-02-03 22:30:38 +08:00
parent 712851a8a5
commit dfb625377b
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
View File

@@ -50,8 +50,6 @@ import java.util.stream.Collectors;
public class TopicManagerServiceImpl implements TopicManagerService { public class TopicManagerServiceImpl implements TopicManagerService {
private static final Logger LOGGER = LoggerFactory.getLogger(TopicManagerServiceImpl.class); private static final Logger LOGGER = LoggerFactory.getLogger(TopicManagerServiceImpl.class);
private static final String CONSUMER_OFFSETS_TOPIC = "__consumer_offsets";
@Autowired @Autowired
private TopicDao topicDao; private TopicDao topicDao;
@@ -277,7 +275,7 @@ public class TopicManagerServiceImpl implements TopicManagerService {
} }
Map<Long, Map<String, TopicDO>> topicMap = new HashMap<>(appList.size()); Map<Long, Map<String, TopicDO>> topicMap = new HashMap<>(appList.size());
for (TopicDO topicDO: topicList) { for (TopicDO topicDO: topicList) {
if (topicDO.getTopicName().equals(CONSUMER_OFFSETS_TOPIC)) { if (topicDO.getTopicName().equals(KafkaConstant.COORDINATOR_TOPIC_NAME)) {
continue; continue;
} }
Map<String, TopicDO> subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>()); Map<String, TopicDO> subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>());