Replace the consumer-fetch-manager-metrics by groupName

apache · Sep 30, 2024 · e6d111e · e6d111e
1 parent 6ee46ea
commit e6d111e
Showing 1 changed file with 1 addition and 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
@@ -141,7 +141,7 @@ public FetchMetricsRegistry(Set<String> 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);
     }