public static class MetadataClient.ClusterMetadata extends Object
Constructor and Description |
---|
ClusterMetadata(org.apache.kafka.common.Cluster cluster,
Map<String,kafka.common.TopicPlacement> topicPlacements,
Map<Integer,String> brokerReplicaExclusions) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.Cluster |
cluster() |
Map<Integer,String> |
replicaExclusions() |
Map<String,kafka.common.TopicPlacement> |
topicPlacements() |
public ClusterMetadata(org.apache.kafka.common.Cluster cluster, Map<String,kafka.common.TopicPlacement> topicPlacements, Map<Integer,String> brokerReplicaExclusions)
cluster
- - the Kafka clustertopicPlacements
- - a map of topic names to their TopicPlacement
configurationsbrokerReplicaExclusions
- - a map of broker ids to the reason they're excluded for replica placement