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

Class KafkaConsumerMetrics

java.lang.Object
org.apache.kafka.clients.consumer.internals.KafkaConsumerMetrics
All Implemented Interfaces:
AutoCloseable
public class KafkaConsumerMetrics extends Object implements AutoCloseable

  • Constructor Details

    • KafkaConsumerMetrics

      public KafkaConsumerMetrics(org.apache.kafka.common.metrics.Metrics metrics, String metricGrpPrefix)

  • Method Details

    • recordPollStart

      public void recordPollStart(long pollStartMs)

    • recordPollEnd

      public void recordPollEnd(long pollEndMs)

    • recordCommitSync

      public void recordCommitSync(long duration)

    • recordCommitted

      public void recordCommitted(long duration)

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable