Class ConsumerLagCollector

java.lang.Object

io.confluent.telemetry.collector.ConsumerLagCollector

All Implemented Interfaces:

MetricsCollector

public class ConsumerLagCollector
extends Object
implements MetricsCollector

Collects consumer lag metrics, max pending rebalance time metrics, and consumer group status metrics from the ConsumerLagStore and emits them via the telemetry pipeline.

Field Summary

Fields inherited from interface io.confluent.telemetry.collector.MetricsCollector

LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE

Constructor Summary

Constructors

Constructor	Description
ConsumerLagCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)

Method Summary

Modifier and Type	Method	Description
void	collect(Emitter emitter)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.telemetry.collector.MetricsCollector

start, stop

Constructor Details

ConsumerLagCollector

public ConsumerLagCollector(MetricNamingStrategy<org.apache.kafka.common.MetricName> metricNamingStrategy)

Method Details

collect

public void collect(Emitter emitter)

Specified by:

collect in interface MetricsCollector