public class KafkaCluster extends Object
DescribeClusterResult
Constructor and Description |
---|
KafkaCluster(Collection<org.apache.kafka.common.Node> nodes,
org.apache.kafka.common.Node controller,
String clusterId,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations) |
Modifier and Type | Method and Description |
---|---|
Set<org.apache.kafka.common.acl.AclOperation> |
authorizedOperations()
The authorized operations.
|
String |
clusterId()
The current cluster id.
|
org.apache.kafka.common.Node |
controller()
The current controller id.
|
Collection<org.apache.kafka.common.Node> |
nodes()
A collection of nodes that consist the Kafka Cluster.
|
public KafkaCluster(Collection<org.apache.kafka.common.Node> nodes, org.apache.kafka.common.Node controller, String clusterId, Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
public Collection<org.apache.kafka.common.Node> nodes()
public org.apache.kafka.common.Node controller()
public String clusterId()
public Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations()