Package org.apache.kafka.clients.admin

Class DescribeClusterResult

java.lang.Object
org.apache.kafka.clients.admin.DescribeClusterResult
public class DescribeClusterResultextends Object
The result of the Admin.describeCluster() call.

  • Method Details

    • nodes

      public KafkaFuture<Collection<Node>> nodes()
      Returns a future which yields a collection of nodes.

    • controller

      public KafkaFuture<Node> controller()
      Returns a future which yields the current controller id. Note that this may yield null, if the controller ID is not yet known.

    • clusterId

      public KafkaFuture<String> clusterId()
      Returns a future which yields the current cluster id. The future value will be non-null if the broker version is 0.10.1.0 or higher and null otherwise.

    • authorizedOperations

      public KafkaFuture<Set<AclOperation>> authorizedOperations()
      Returns a future which yields authorized operations. The future value will be non-null if the broker supplied this information, and null otherwise.