Package com.linkedin.davinci.stats
Enum Class KafkaConsumerServiceOtelMetricEntity
java.lang.Object
java.lang.Enum<KafkaConsumerServiceOtelMetricEntity>
com.linkedin.davinci.stats.KafkaConsumerServiceOtelMetricEntity
- All Implemented Interfaces:
ModuleMetricEntityInterface,Serializable,Comparable<KafkaConsumerServiceOtelMetricEntity>,Constable
public enum KafkaConsumerServiceOtelMetricEntity
extends Enum<KafkaConsumerServiceOtelMetricEntity>
implements ModuleMetricEntityInterface
OTel metric entity definitions for
KafkaConsumerServiceStats.
Uses pubsub (not kafka) in metric names to align with Venice's PubSub abstraction.
Tehuti names are preserved as-is for backward compatibility.-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Enum
Enum.EnumDesc<E extends Enum<E>> -
Enum Constant Summary
Enum ConstantsEnum ConstantDescriptionRaw per-consumer partition assignment counts.Max elapsed time since the last successful poll across all consumers in the pool.Latency of consumer pool actions (subscribe, update assignment). -
Method Summary
Modifier and TypeMethodDescriptionReturns the enum constant of this class with the specified name.static KafkaConsumerServiceOtelMetricEntity[]values()Returns an array containing the constants of this enum class, in the order they are declared.Methods inherited from class java.lang.Enum
clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOfMethods inherited from interface com.linkedin.venice.stats.metrics.ModuleMetricEntityInterface
getMetricName
-
Enum Constant Details
-
POLL_BYTES
-
POLL_RECORD_COUNT
-
POLL_COUNT
-
POLL_TIME
-
POLL_NON_EMPTY_COUNT
-
POLL_ERROR_COUNT
-
PRODUCE_TO_WRITE_BUFFER_TIME
-
TOPIC_DETECTED_DELETED_COUNT
-
ORPHAN_TOPIC_PARTITION_COUNT
-
POOL_ACTION_TIME
Latency of consumer pool actions (subscribe, update assignment). Shared OTel instrument differentiated byVeniceConsumerPoolAction. -
POLL_TIME_SINCE_LAST_SUCCESS
Max elapsed time since the last successful poll across all consumers in the pool. Captures the same value as the Tehutiidle_timesensor. The Tehutimax_elapsed_time_since_last_successful_pollAsyncGauge is intentionally excluded from OTel because it reads from the same source method (KafkaConsumerService.getMaxElapsedTimeMSSinceLastPollInConsumerPool()) and would be redundant. -
PARTITION_ASSIGNMENT_COUNT
Raw per-consumer partition assignment counts. OTel-only (Tehuti uses 4 pre-computed gauges).
-
-
Method Details
-
values
Returns an array containing the constants of this enum class, in the order they are declared.- Returns:
- an array containing the constants of this enum class, in the order they are declared
-
valueOf
Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)- Parameters:
name- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
IllegalArgumentException- if this enum class has no constant with the specified nameNullPointerException- if the argument is null
-
getMetricEntity
- Specified by:
getMetricEntityin interfaceModuleMetricEntityInterface
-