From cfd7d94108400422a9b18d87332d698b2d301ebc Mon Sep 17 00:00:00 2001 From: xijiu <422766572@qq.com> Date: Wed, 2 Oct 2024 12:38:40 +0800 Subject: [PATCH] KAFKA-17657 Replace the consumer-fetch-manager-metrics by groupName (#17317) Reviewers: Chia-Ping Tsai --- .../kafka/clients/consumer/internals/FetchMetricsRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java index 54dddf653ad52..b0e69bb22a389 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java @@ -141,7 +141,7 @@ public FetchMetricsRegistry(Set tags, String metricGrpPrefix) { this.partitionRecordsLeadAvg = new MetricNameTemplate("records-lead-avg", groupName, "The average lead of the partition", partitionTags); this.partitionPreferredReadReplica = new MetricNameTemplate( - "preferred-read-replica", "consumer-fetch-manager-metrics", + "preferred-read-replica", groupName, "The current read replica for the partition, or -1 if reading from leader", partitionTags); }