public interface MetricSamplerPartitionAssignor extends CruiseControlConfigurable
Modifier and Type | Method and Description |
---|---|
Set<org.apache.kafka.common.PartitionInfo> |
assignPartitions(org.apache.kafka.common.Cluster cluster)
Assign the partitions in the cluster to the single metric fetcher.
|
configure
Set<org.apache.kafka.common.PartitionInfo> assignPartitions(org.apache.kafka.common.Cluster cluster)
cluster
- The Kafka cluster