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

Remove __consumer_offsets from topic list

Browse Source
This commit is contained in:
17hao
2021-02-03 15:50:33 +08:00
parent 9271a1caac
commit 63d291cb47
1 changed files with 4 additions and 0 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,6 +50,8 @@ 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;
@@ -275,6 +277,8 @@ 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))
continue;
Map<String, TopicDO> subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>()); Map<String, TopicDO> subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>());
subTopicMap.put(topicDO.getTopicName(), topicDO); subTopicMap.put(topicDO.getTopicName(), topicDO);
topicMap.put(topicDO.getClusterId(), subTopicMap); topicMap.put(topicDO.getClusterId(), subTopicMap);