|
@@ -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<ClusterDescription> 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) {
|