public static class MetadataClient.ClusterMetadata extends Object
Constructor and Description |
---|
ClusterMetadata(org.apache.kafka.common.Cluster cluster,
Optional<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() |
Optional<Map<String,kafka.common.TopicPlacement>> |
topicPlacements() |
public ClusterMetadata(org.apache.kafka.common.Cluster cluster, Optional<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