public class CruiseControlMetricsProcessor extends Object
ConfluentTelemetryReporterSampler
from the Kafka cluster.Constructor and Description |
---|
CruiseControlMetricsProcessor(BrokerCapacityConfigResolver brokerCapacityConfigResolver,
KafkaCruiseControlConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
addMetric(CruiseControlMetric metric) |
void |
clear() |
MetricSampler.Samples |
process(org.apache.kafka.common.Cluster cluster,
Set<org.apache.kafka.common.PartitionInfo> partitions)
Process all the added
CruiseControlMetric to get the MetricSampler.Samples |
public CruiseControlMetricsProcessor(BrokerCapacityConfigResolver brokerCapacityConfigResolver, KafkaCruiseControlConfig config)
brokerCapacityConfigResolver
- The resolver for retrieving broker capacities.config
- Providing the values for different weights estimates and if CPU capacity estimation should be enabled.public void addMetric(CruiseControlMetric metric)
public MetricSampler.Samples process(org.apache.kafka.common.Cluster cluster, Set<org.apache.kafka.common.PartitionInfo> partitions)
CruiseControlMetric
to get the MetricSampler.Samples
cluster
- Kafka cluster.partitions
- Partitions to construct samples for.public void clear()