public class ZkClusterDescriber extends Object implements org.apache.kafka.metadata.placement.ClusterDescriber
Constructor and Description |
---|
ZkClusterDescriber(org.apache.kafka.common.Cluster cluster) |
Modifier and Type | Method and Description |
---|---|
static List<List<Integer>> |
partitionInfosToReplicas(List<org.apache.kafka.common.PartitionInfo> partitions) |
List<List<Integer>> |
replicasForTopicName(String topicName) |
Iterator<String> |
topicNames() |
Iterator<org.apache.kafka.metadata.placement.UsableBroker> |
usableBrokers() |
public ZkClusterDescriber(org.apache.kafka.common.Cluster cluster)
public static List<List<Integer>> partitionInfosToReplicas(List<org.apache.kafka.common.PartitionInfo> partitions)
public Iterator<org.apache.kafka.metadata.placement.UsableBroker> usableBrokers()
usableBrokers
in interface org.apache.kafka.metadata.placement.ClusterDescriber
public Iterator<String> topicNames()
topicNames
in interface org.apache.kafka.metadata.placement.ClusterDescriber