Package com.linkedin.davinci.stats

Class KafkaConsumerServiceStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.davinci.stats.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.

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats

DELIMITER

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerServiceStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool, KafkaConsumerServiceStats totalStats, Time time)

Method Summary

Modifier and Type	Method	Description
void	recordAvgPartitionsPerConsumer(int count)
void	recordByteSizePerPoll(double count)
void	recordConsumerIdleTime(double time)
void	recordConsumerRecordsProducingToWriterBufferLatency(double latency)
void	recordDelegateSubscribeLatency(double value)
void	recordDetectedDeletedTopicNum(int count)
void	recordDetectedNoRunningIngestionTopicPartitionNum(int count)
void	recordLatestOffsetIsAbsent()
void	recordLatestOffsetIsPresent()
void	recordMaxPartitionsPerConsumer(int count)
void	recordMinPartitionsPerConsumer(int count)
void	recordNonZeroPollResultNum(int count)
void	recordOffsetLagIsAbsent()
void	recordOffsetLagIsPresent()
void	recordPollError()
void	recordPollRequestLatency(double latency)
void	recordPollResultNum(int count)
void	recordSubscribedPartitionsNum(int count)
void	recordUpdateCurrentAssignmentLatency(double value)

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConsumerServiceStats

public KafkaConsumerServiceStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool,
 KafkaConsumerServiceStats totalStats,
 Time time)

Method Details

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)