public class ConfluentMetricsReporterSampler extends ConfluentMetricsSamplerBase
MetricSampler.Samples
METRIC_SAMPLER_BOOTSTRAP_SERVERS, METRIC_SAMPLER_GROUP_ID, metricConsumer, TELEMETRY_REPORTER_TOPIC_PATTERN
EMPTY_SAMPLES
Constructor and Description |
---|
ConfluentMetricsReporterSampler() |
Modifier and Type | Method and Description |
---|---|
protected List<CruiseControlMetric> |
convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> confluentMetric) |
checkIfMetricReporterTopicExist, checkStartupCondition, close, configure, createConsumerForMetricTopic, getMetricConsumerProperties, getMetricReporterTopic, getSamples
protected List<CruiseControlMetric> convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> confluentMetric)
convertMetricRecord
in class ConfluentMetricsSamplerBase