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

Add braces

Browse Source
This commit is contained in:
17hao
2021-02-03 16:06:16 +08:00
parent 63d291cb47
commit 712851a8a5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -277,8 +277,9 @@ 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(CONSUMER_OFFSETS_TOPIC)) {
continue; 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);