From 7abf5db187e8ee54f3c5bebc8e802f1d1e39efc6 Mon Sep 17 00:00:00 2001 From: Ilya Kuramshin Date: Mon, 11 Oct 2021 15:46:17 +0300 Subject: [PATCH] unnecessary option passing removed (#958) Co-authored-by: Ilya Kuramshin --- .../com/provectus/kafka/ui/service/ReactiveAdminClient.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ReactiveAdminClient.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ReactiveAdminClient.java index 644da58cd2..0d1e81e9e0 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ReactiveAdminClient.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ReactiveAdminClient.java @@ -25,7 +25,6 @@ import org.apache.kafka.clients.admin.Config; import org.apache.kafka.clients.admin.ConfigEntry; import org.apache.kafka.clients.admin.ConsumerGroupDescription; import org.apache.kafka.clients.admin.ConsumerGroupListing; -import org.apache.kafka.clients.admin.DescribeClusterOptions; import org.apache.kafka.clients.admin.DescribeConfigsOptions; import org.apache.kafka.clients.admin.ListTopicsOptions; import org.apache.kafka.clients.admin.NewPartitionReassignment; @@ -144,7 +143,7 @@ public class ReactiveAdminClient implements Closeable { } public Mono describeCluster() { - var r = client.describeCluster(new DescribeClusterOptions().includeAuthorizedOperations(true)); + var r = client.describeCluster(); var all = KafkaFuture.allOf(r.nodes(), r.clusterId(), r.controller(), r.authorizedOperations()); return Mono.create(sink -> all.whenComplete((res, ex) -> { if (ex != null) {