root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-17657 Replace the consumer-fetch-manager-metrics by groupName (#17317) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
xijiu 2024-10-02 12:38:40 +08:00 committed by GitHub
parent 49d7ea6c6a
commit cfd7d94108
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java
View File

@ -141,7 +141,7 @@ public class FetchMetricsRegistry {
this.partitionRecordsLeadAvg = new MetricNameTemplate("records-lead-avg", groupName, this.partitionRecordsLeadAvg = new MetricNameTemplate("records-lead-avg", groupName,
"The average lead of the partition", partitionTags); "The average lead of the partition", partitionTags);
this.partitionPreferredReadReplica = new MetricNameTemplate( 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); "The current read replica for the partition, or -1 if reading from leader", partitionTags);
} }