public static class MetadataClient.ClusterAndGeneration extends Object
Constructor and Description |
---|
ClusterAndGeneration(MetadataClient.ClusterMetadata cluster,
int generation) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.Cluster |
cluster() |
Map<Integer,List<String>> |
degradedBrokers() |
int |
generation() |
Set<org.apache.kafka.common.TopicPartition> |
reassigningPartitions() |
Map<Integer,String> |
replicaExclusions() |
Set<Tenant> |
tenants()
Returns all tenants in the cluster.
|
Optional<Map<String,kafka.common.TopicPlacement>> |
topicPlacements() |
String |
toString() |
public ClusterAndGeneration(MetadataClient.ClusterMetadata cluster, int generation)
public org.apache.kafka.common.Cluster cluster()
public Map<Integer,String> replicaExclusions()
public Set<org.apache.kafka.common.TopicPartition> reassigningPartitions()
public int generation()