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); }