public class ConfluentMetricsReporterSampler extends ConfluentMetricsSamplerBase
MetricSampler.Samples, MetricSampler.SamplingMode
LOG, 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 java.util.List<CruiseControlMetric> |
convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> confluentMetric) |
protected java.lang.String |
defaultMetricSamplerGroupId() |
checkIfMetricReporterTopicExist, checkStartupCondition, close, configure, createConsumerForMetricTopic, getMetricConsumerProperties, getMetricReporterTopic, getSamples
protected java.util.List<CruiseControlMetric> convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> confluentMetric)
convertMetricRecord
in class ConfluentMetricsSamplerBase
protected java.lang.String defaultMetricSamplerGroupId()
defaultMetricSamplerGroupId
in class ConfluentMetricsSamplerBase