(kafka) branch trunk updated: KAFKA-17749: Fix Throttler metrics name (#17430)

[mimaison]

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new dcd3bbe5929 KAFKA-17749: Fix Throttler metrics name (#17430)
dcd3bbe5929 is described below

commit dcd3bbe5929d9ee558a16de04c99c504c8c1c3ac
Author: Mickael Maison <mimai...@users.noreply.github.com>
AuthorDate: Thu Oct 10 17:25:59 2024 +0200

    KAFKA-17749: Fix Throttler metrics name (#17430)
    
    
    Reviewers: Josep Prat <josep.p...@aiven.io>
---
 .../main/java/org/apache/kafka/storage/internals/utils/Throttler.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java 
b/storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java
index b4e7fc0c103..01d8e585d21 100644
--- 
a/storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java
+++ 
b/storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java
@@ -62,7 +62,8 @@ public class Throttler {
                      Time time) {
         this.desiredRatePerSec = desiredRatePerSec;
         this.checkIntervalNs = TimeUnit.MILLISECONDS.toNanos(checkIntervalMs);
-        this.meter = new 
KafkaMetricsGroup(Throttler.class).newMeter(metricName, units, 
TimeUnit.SECONDS);
+        // For compatibility - this metrics group was previously defined 
within a Scala class named `kafka.utils.Throttler`
+        this.meter = new KafkaMetricsGroup("kafka.utils", 
"Throttler").newMeter(metricName, units, TimeUnit.SECONDS);
         this.time = time;
         this.periodStartNs = time.nanoseconds();
     }