Skip to content

Commit d3c8075

Browse files
committed
address review comments
1 parent 03fb92a commit d3c8075

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

clients/da-vinci-client/src/main/java/com/linkedin/davinci/stats/KafkaConsumerServiceOtelMetricEntity.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public enum KafkaConsumerServiceOtelMetricEntity implements ModuleMetricEntityIn
6060
),
6161

6262
ORPHAN_TOPIC_PARTITION_COUNT(
63-
"ingestion.pubsub.consumer.topic.partition.orphan_count", MetricType.COUNTER, MetricUnit.NUMBER,
63+
"ingestion.pubsub.consumer.orphan_subscription_count", MetricType.COUNTER, MetricUnit.NUMBER,
6464
"Count of topic-partitions assigned to consumer with no running ingestion task", setOf(VENICE_CLUSTER_NAME)
6565
),
6666

clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/KafkaConsumerServiceOtelMetricEntityTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ private static Map<KafkaConsumerServiceOtelMetricEntity, MetricEntityExpectation
101101
map.put(
102102
ORPHAN_TOPIC_PARTITION_COUNT,
103103
new MetricEntityExpectation(
104-
"ingestion.pubsub.consumer.topic.partition.orphan_count",
104+
"ingestion.pubsub.consumer.orphan_subscription_count",
105105
MetricType.COUNTER,
106106
MetricUnit.NUMBER,
107107
"Count of topic-partitions assigned to consumer with no running ingestion task",

0 commit comments

Comments
 (0)