Package io.confluent.telemetry.collector
package io.confluent.telemetry.collector
-
ClassDescriptionThis class encapsulates Confluent naming and mapping conventions defined as part of https://confluentinc.atlassian.net/wiki/spaces/OBSERVE/pages/890537142/Metrics+ConventionsCollects consumer lag metrics, max pending rebalance time metrics, and consumer group status metrics from the ConsumerLagStore and emits them via the telemetry pipeline.A LastValueTracker uses a ConcurrentMap to maintain historic values for a given key, and return a previous value and an Instant for that value.A metrics collector that emits a single metric representing that this node is up in this cluster.A wrapper around
JvmMetricsCollectorthat ensures only one collector instance exists per JVM process, even when multipleTelemetryReporterinstances are running.A MetricsCollector that ensures exactly one metric will be exported per minute by oversampling the metric source every 30 seconds.