diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/kafka/KafkaService.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/kafka/KafkaService.java index c3f97b83f1..aaadef4486 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/kafka/KafkaService.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/kafka/KafkaService.java @@ -53,7 +53,7 @@ public class KafkaService { getTopicsData(ac.getAdminClient()).flatMap( topics -> loadTopicsConfig(ac.getAdminClient(), topics.stream().map(InternalTopic::getName).collect(Collectors.toList())) .map( configs -> mergeWithConfigs(topics, configs)) - .flatMap(it -> updateSegmentMetrics(ac, clusterMetrics, it)) + .flatMap(it -> updateSegmentMetrics(ac.getAdminClient(), clusterMetrics, it)) ).map( segmentSizeDto -> buildFromData(cluster, segmentSizeDto)) ) ).onErrorResume(