From ec7c8bbf5eda1ec4c0e8c5bdb45e23b7b9a881de Mon Sep 17 00:00:00 2001 From: Anton Petrov Date: Thu, 28 May 2020 14:37:23 +0300 Subject: [PATCH] Fix compilation error (#53) --- .../main/java/com/provectus/kafka/ui/kafka/KafkaService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(