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, java.lang.String storeName, java.util.function.LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool, KafkaConsumerServiceStats totalStats, Time time)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
recordUpdateCurrentAssignmentLatency(double value)
-
Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats
avgAndMax, avgAndTotal, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors
-
-
-
-
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)
-
-