public class MetricFetcherManager extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BROKER_CAPACITY_CONFIG_RESOLVER_OBJECT_CONFIG |
static String |
DEFAULT_BROKER_CAPACITY_CONFIG_RESOLVER_OBJECT_CONFIG |
Constructor and Description |
---|
MetricFetcherManager(KafkaCruiseControlConfig config,
KafkaReplicaMetricSampleAggregator replicaMetricSampleAggregator,
KafkaPartitionMetricSampleAggregator partitionMetricSampleAggregator,
org.apache.kafka.common.utils.Time time,
DataBalancerMetricsRegistry metricRegistry,
BrokerCapacityConfigResolver brokerCapacityConfigResolver,
MetricSampler sampler)
Create a metric fetcher manager.
|
Modifier and Type | Method and Description |
---|---|
boolean |
fetchSamples(SamplingOptions samplingOptions,
long timeoutMs)
Fetches the metric samples for a given period.
|
void |
shutdown()
Shutdown the metric fetcher manager.
|
void |
start() |
public static final String BROKER_CAPACITY_CONFIG_RESOLVER_OBJECT_CONFIG
public static final String DEFAULT_BROKER_CAPACITY_CONFIG_RESOLVER_OBJECT_CONFIG
public MetricFetcherManager(KafkaCruiseControlConfig config, KafkaReplicaMetricSampleAggregator replicaMetricSampleAggregator, KafkaPartitionMetricSampleAggregator partitionMetricSampleAggregator, org.apache.kafka.common.utils.Time time, DataBalancerMetricsRegistry metricRegistry, BrokerCapacityConfigResolver brokerCapacityConfigResolver, MetricSampler sampler)
config
- The load monitor configurations.partitionMetricSampleAggregator
- The KafkaPartitionMetricSampleAggregator
to aggregate partition metrics.time
- The time object.metricRegistry
- The Metric Registry object.brokerCapacityConfigResolver
- The resolver for retrieving broker capacities.public void start()
public void shutdown()
public boolean fetchSamples(SamplingOptions samplingOptions, long timeoutMs)
samplingOptions
- the configurations with which to sample.timeoutMs
- the timeout.