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