Package com.linkedin.davinci.stats

Class AggKafkaConsumerServiceStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceAggStats<T>

com.linkedin.venice.stats.AbstractVeniceAggStoreStats<KafkaConsumerServiceStats>

com.linkedin.davinci.stats.AggKafkaConsumerServiceStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggKafkaConsumerServiceStats
extends AbstractVeniceAggStoreStats<KafkaConsumerServiceStats>

This class is an aggregate place that keeps stats objects for multiple stores and total stats for each region for AggKafkaConsumerService. For total stats for a given region, use this class to record stats. For store-level stats, delegate them to KafkaConsumerServiceStats.

Field Summary

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

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AggKafkaConsumerServiceStats(String regionName, io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool, boolean isUnregisterMetricForDeletedStoreEnabled, String veniceClusterName)

Method Summary

Modifier and Type	Method	Description
void	recordTotalAvgPartitionsPerConsumer(int count)
void	recordTotalConsumerIdleTime(double idleTime)
void	recordTotalConsumerRecordsProducingToWriterBufferLatency(double latency)
void	recordTotalDelegateSubscribeLatency(double value)
void	recordTotalDetectedDeletedTopicNum(int count)
void	recordTotalDetectedNoRunningIngestionTopicPartitionNum(int count)
void	recordTotalMaxPartitionsPerConsumer(int count)
void	recordTotalMinPartitionsPerConsumer(int count)
void	recordTotalNonZeroPollResultNum(int count)
void	recordTotalPartitionAssignmentForOtel(int partitionCount)	Records a single per-consumer partition count to the OTel partition assignment histogram on the total stats instance.
void	recordTotalPollError()
void	recordTotalPollRequestLatency(double latency)
void	recordTotalSubscribedPartitionsNum(int count)
void	recordTotalUpdateCurrentAssignmentLatency(double value)

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

getStoreStats, handleStoreDeleted

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

getNullableStoreStats, getTotalStats, setStatsSupplier

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.meta.StoreDataChangedListener

handleStoreChanged, handleStoreCreated, handleStoreDeleted

Constructor Details

AggKafkaConsumerServiceStats

public AggKafkaConsumerServiceStats(String regionName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 LongSupplier getMaxElapsedTimeSinceLastPollInConsumerPool,
 boolean isUnregisterMetricForDeletedStoreEnabled,
 String veniceClusterName)

Method Details

recordTotalConsumerIdleTime

public void recordTotalConsumerIdleTime(double idleTime)

recordTotalPollRequestLatency

public void recordTotalPollRequestLatency(double latency)

recordTotalNonZeroPollResultNum

public void recordTotalNonZeroPollResultNum(int count)

recordTotalConsumerRecordsProducingToWriterBufferLatency

public void recordTotalConsumerRecordsProducingToWriterBufferLatency(double latency)

recordTotalPollError

public void recordTotalPollError()

recordTotalDetectedDeletedTopicNum

public void recordTotalDetectedDeletedTopicNum(int count)

recordTotalDetectedNoRunningIngestionTopicPartitionNum

public void recordTotalDetectedNoRunningIngestionTopicPartitionNum(int count)

recordTotalDelegateSubscribeLatency

public void recordTotalDelegateSubscribeLatency(double value)

recordTotalUpdateCurrentAssignmentLatency

public void recordTotalUpdateCurrentAssignmentLatency(double value)

recordTotalMinPartitionsPerConsumer

public void recordTotalMinPartitionsPerConsumer(int count)

recordTotalMaxPartitionsPerConsumer

public void recordTotalMaxPartitionsPerConsumer(int count)

recordTotalAvgPartitionsPerConsumer

public void recordTotalAvgPartitionsPerConsumer(int count)

recordTotalSubscribedPartitionsNum

public void recordTotalSubscribedPartitionsNum(int count)

recordTotalPartitionAssignmentForOtel

public void recordTotalPartitionAssignmentForOtel(int partitionCount)

Records a single per-consumer partition count to the OTel partition assignment histogram on the total stats instance. Called for each consumer in the pool from KafkaConsumerService.recordPartitionsPerConsumerSensor().