Merge branch 'trunk' into KAFKA-12895

apache · Oct 2, 2024 · f63394d · f63394d
2 parents 70554d6 + cfd7d94
commit f63394d
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);
     }