public class ConfluentTelemetryReporterSampler extends ConfluentMetricsSamplerBase
MetricSampler.Samples, MetricSampler.SamplingMode
METRIC_SAMPLER_BOOTSTRAP_SERVERS, METRIC_SAMPLER_GROUP_ID, metricConsumer, TELEMETRY_REPORTER_TOPIC_PATTERN
EMPTY_SAMPLES
Constructor and Description |
---|
ConfluentTelemetryReporterSampler() |
Modifier and Type | Method and Description |
---|---|
protected List<CruiseControlMetric> |
convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
This is performance sensitive code due to SBC consuming partition granularity metrics for disk usage.
|
protected String |
defaultMetricSamplerGroupId() |
checkIfMetricReporterTopicExist, checkStartupCondition, close, configure, createConsumerForMetricTopic, getMetricConsumerProperties, getMetricReporterTopic, getSamples
protected List<CruiseControlMetric> convertMetricRecord(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
convertMetricRecord
in class ConfluentMetricsSamplerBase
protected String defaultMetricSamplerGroupId()
defaultMetricSamplerGroupId
in class ConfluentMetricsSamplerBase