diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ZookeeperServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ZookeeperServiceImpl.java index c4c89513..cb9827bd 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ZookeeperServiceImpl.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ZookeeperServiceImpl.java @@ -28,7 +28,7 @@ public class ZookeeperServiceImpl implements ZookeeperService { @Override public Result openTopicJmx(Long clusterId, String topicName, TopicJmxSwitch jmxSwitch) { - if (ValidateUtils.isNull(clusterId) || ValidateUtils.isNull(topicName)) { + if (ValidateUtils.isNull(clusterId) || ValidateUtils.isNull(topicName) || ValidateUtils.isNull(jmxSwitch)) { return Result.buildFrom(ResultStatus.PARAM_ILLEGAL); }