diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ZookeeperService.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ZookeeperService.java index fb0ec918b4..02123ac957 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ZookeeperService.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ZookeeperService.java @@ -7,6 +7,7 @@ import lombok.RequiredArgsConstructor; import lombok.extern.log4j.Log4j2; import org.I0Itec.zkclient.ZkClient; import org.springframework.stereotype.Service; +import org.springframework.util.StringUtils; @Service @RequiredArgsConstructor @@ -17,10 +18,12 @@ public class ZookeeperService { public boolean isZookeeperOnline(KafkaCluster kafkaCluster) { var isConnected = false; - var zkClient = getOrCreateZkClient(kafkaCluster); - log.debug("Start getting Zookeeper metrics for kafkaCluster: {}", kafkaCluster.getName()); - if (zkClient != null) { - isConnected = isZkClientConnected(zkClient); + if (StringUtils.hasText(kafkaCluster.getZookeeper())) { + var zkClient = getOrCreateZkClient(kafkaCluster); + log.debug("Start getting Zookeeper metrics for kafkaCluster: {}", kafkaCluster.getName()); + if (zkClient != null) { + isConnected = isZkClientConnected(zkClient); + } } return isConnected; }