diff --git a/server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java b/server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java index e4b7afc3eac9f..329083350cdc8 100644 --- a/server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java +++ b/server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java @@ -22,6 +22,7 @@ import org.apache.kafka.common.Reconfigurable; import org.apache.kafka.common.config.ConfigException; import org.apache.kafka.common.metrics.JmxReporter; +import org.apache.kafka.common.utils.Exit; import org.apache.kafka.common.utils.Sanitizer; import java.util.Iterator; @@ -57,7 +58,7 @@ public static MetricsRegistry defaultRegistry() { private KafkaYammerMetrics() { jmxReporter.start(); - Runtime.getRuntime().addShutdownHook(new Thread(jmxReporter::shutdown)); + Exit.addShutdownHook("kafka-jmx-shutdown-hook", jmxReporter::shutdown); } @Override