Package org.apache.kafka.clients.consumer.internals

Class FetchMetricsManager

java.lang.Object

org.apache.kafka.clients.consumer.internals.FetchMetricsManager

public class FetchMetricsManager
extends Object

The FetchMetricsManager class provides wrapper methods to record lag, lead, latency, and fetch metrics. It keeps an internal ID of the assigned set of partitions which is updated to ensure the set of metrics it records matches up with the topic-partitions in use.

Constructor Summary

Constructors

Constructor	Description
FetchMetricsManager(org.apache.kafka.common.metrics.Metrics metrics, FetchMetricsRegistry metricsRegistry)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.metrics.Sensor	throttleTimeSensor()

Methods inherited from class java.lang.Object

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

Constructor Details

FetchMetricsManager

public FetchMetricsManager(org.apache.kafka.common.metrics.Metrics metrics,
 FetchMetricsRegistry metricsRegistry)

Method Details

throttleTimeSensor

public org.apache.kafka.common.metrics.Sensor throttleTimeSensor()