diff --git a/docs/upgrade.html b/docs/upgrade.html
index faa4862154acc..478d9f0488cc0 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -41,6 +41,9 @@
In 3.8.0 the kafka.utils.Thottler
metric was accidentally renamed to org.apache.kafka.storage.internals.utils.Throttler
.
+ This change has been reverted and the metric is now named kafka.utils.Thottler
again.
+
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 b4e7fc0c10377..01d8e585d218c 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 Throttler(double desiredRatePerSec,
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();
}