public interface MetricSamplerPartitionAssignor extends CruiseControlConfigurable
Modifier and Type | Method and Description |
---|---|
java.util.Set<org.apache.kafka.common.TopicPartition> |
assignPartitions(org.apache.kafka.common.Cluster cluster)
Assign the partitions in the cluster to the single metric fetcher.
|
java.util.List<java.util.Set<org.apache.kafka.common.TopicPartition>> |
assignPartitions(org.apache.kafka.common.Cluster cluster,
int numFetchers)
Deprecated.
Please use
assignPartitions(Cluster) .
Assign the partitions in the cluster to the metric fetchers. |
configure
@Deprecated java.util.List<java.util.Set<org.apache.kafka.common.TopicPartition>> assignPartitions(org.apache.kafka.common.Cluster cluster, int numFetchers)
assignPartitions(Cluster)
.
Assign the partitions in the cluster to the metric fetchers.cluster
- The Kafka cluster.numFetchers
- The number of metric fetchers.java.util.Set<org.apache.kafka.common.TopicPartition> assignPartitions(org.apache.kafka.common.Cluster cluster)
cluster
- The Kafka cluster