Package com.linkedin.davinci.stats

Class KafkaConsumerServiceStats

  • public class KafkaConsumerServiceStats
extends AbstractVeniceStats
    This class provides the stats for Kafka consumer service per region or per store. Stats inside this class can either: (1) Total only: The stat indicate total number of all the stores on this host per region. (2) Total and Per store only: The stat is registered for each store on this host.

    • Constructor Detail

      • KafkaConsumerServiceStats

        public KafkaConsumerServiceStats​(io.tehuti.metrics.MetricsRepository metricsRepository,
                                 java.lang.String storeName,
                                 java.util.function.LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool,
                                 KafkaConsumerServiceStats totalStats,
                                 Time time)

    • Method Detail

      • recordPollRequestLatency

        public void recordPollRequestLatency​(double latency)

      • recordPollResultNum

        public void recordPollResultNum​(int count)

      • recordNonZeroPollResultNum

        public void recordNonZeroPollResultNum​(int count)

      • recordConsumerRecordsProducingToWriterBufferLatency

        public void recordConsumerRecordsProducingToWriterBufferLatency​(double latency)

      • recordPollError

        public void recordPollError()

      • recordDetectedDeletedTopicNum

        public void recordDetectedDeletedTopicNum​(int count)

      • recordDetectedNoRunningIngestionTopicPartitionNum

        public void recordDetectedNoRunningIngestionTopicPartitionNum​(int count)

      • recordDelegateSubscribeLatency

        public void recordDelegateSubscribeLatency​(double value)

      • recordUpdateCurrentAssignmentLatency

        public void recordUpdateCurrentAssignmentLatency​(double value)

      • recordMinPartitionsPerConsumer

        public void recordMinPartitionsPerConsumer​(int count)

      • recordMaxPartitionsPerConsumer

        public void recordMaxPartitionsPerConsumer​(int count)

      • recordAvgPartitionsPerConsumer

        public void recordAvgPartitionsPerConsumer​(int count)

      • recordOffsetLagIsAbsent

        public void recordOffsetLagIsAbsent()

      • recordOffsetLagIsPresent

        public void recordOffsetLagIsPresent()

      • recordLatestOffsetIsAbsent

        public void recordLatestOffsetIsAbsent()

      • recordLatestOffsetIsPresent

        public void recordLatestOffsetIsPresent()

      • recordByteSizePerPoll

        public void recordByteSizePerPoll​(double count)

      • recordConsumerIdleTime

        public void recordConsumerIdleTime​(double time)

      • recordSubscribedPartitionsNum

        public void recordSubscribedPartitionsNum​(int count)