Package org.apache.kafka.clients.admin

Class DescribeClusterResult

java.lang.Object

org.apache.kafka.clients.admin.DescribeClusterResult

public class DescribeClusterResult
extends Object

The result of the Admin.describeCluster() call.

Method Summary

Modifier and Type	Method	Description
KafkaFuture<Set<AclOperation>>	authorizedOperations()	Returns a future which yields authorized operations.
KafkaFuture<String>	clusterId()	Returns a future which yields the current cluster id.
KafkaFuture<Node>	controller()	Returns a future which yields the current controller node.
KafkaFuture<Collection<Node>>	nodes()	Returns a future which yields a collection of nodes.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 node.

When using AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, the controller refer to a random broker. When using AdminClientConfig.BOOTSTRAP_CONTROLLERS_CONFIG, it refers to the current voter leader.

clusterId

public KafkaFuture<String> clusterId()

Returns a future which yields the current cluster id.

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.