public class CruiseControlMetricsProcessor extends Object
ConfluentTelemetryReporterSampler
from the Kafka cluster.Constructor and Description |
---|
CruiseControlMetricsProcessor(BrokerCapacityConfigResolver brokerCapacityConfigResolver,
boolean allowCpuCapacityEstimation) |
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.TopicPartition> partitions,
MetricSampler.SamplingMode samplingMode)
Process all the added
CruiseControlMetric to get the MetricSampler.Samples |
public CruiseControlMetricsProcessor(BrokerCapacityConfigResolver brokerCapacityConfigResolver, boolean allowCpuCapacityEstimation)
brokerCapacityConfigResolver
- The resolver for retrieving broker capacities.allowCpuCapacityEstimation
- True to allow CPU capacity estimation of brokers used for CPU utilization estimation.public void addMetric(CruiseControlMetric metric)
public MetricSampler.Samples process(org.apache.kafka.common.Cluster cluster, Set<org.apache.kafka.common.TopicPartition> partitions, MetricSampler.SamplingMode samplingMode)
CruiseControlMetric
to get the MetricSampler.Samples
cluster
- Kafka cluster.partitions
- Partitions to construct samples for.samplingMode
- The sampling mode to indicate which type of samples are needed.public void clear()