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

Update if statements

Browse Source
This commit is contained in:
17hao
2021-02-04 12:32:28 +08:00
parent e8de403286
commit 9491418f3b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -303,12 +303,10 @@ public class TopicManagerServiceImpl implements TopicManagerService {
clusterDO.getId(), clusterDO.getId(),
topicName topicName
); );
if (ValidateUtils.isNull(logicalClusterDO)) {
continue;
}
TopicDO topicDO = topicMap.get(topicName); TopicDO topicDO = topicMap.get(topicName);
if (ValidateUtils.isNull(topicDO)) {
if (ValidateUtils.isNull(topicDO) || ValidateUtils.isNull(logicalClusterDO)) {
continue; continue;
} }