Package org.apache.kafka.clients.admin
Class DescribeClusterResult
java.lang.Object
org.apache.kafka.clients.admin.DescribeClusterResult
The result of the
Admin.describeCluster() call.
The API of this class is evolving, see Admin for details.-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.kafka.common.KafkaFuture<Set<org.apache.kafka.common.acl.AclOperation>> Returns a future which yields authorized operations.org.apache.kafka.common.KafkaFuture<String> Returns a future which yields the current cluster id.org.apache.kafka.common.KafkaFuture<org.apache.kafka.common.Node> Returns a future which yields the current controller id.org.apache.kafka.common.KafkaFuture<Collection<org.apache.kafka.common.Node>> nodes()Returns a future which yields a collection of nodes.
-
Method Details
-
nodes
Returns a future which yields a collection of nodes. -
controller
public org.apache.kafka.common.KafkaFuture<org.apache.kafka.common.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
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 org.apache.kafka.common.KafkaFuture<Set<org.apache.kafka.common.acl.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.
-