From b5a4a347639b96cba7047f259755db1709f72b0a Mon Sep 17 00:00:00 2001 From: Xuan-Zhang Gong Date: Thu, 9 Oct 2025 14:17:58 +0800 Subject: [PATCH] Fix the incorrect package name in metrics and revert the comment --- core/src/main/scala/kafka/network/SocketServer.scala | 2 +- .../scala/unit/kafka/server/AbstractFetcherManagerTest.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index c14c5c665afde..306b633f6fa37 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -833,7 +833,7 @@ private[kafka] class Processor( threadName: String, connectionDisconnectListeners: Seq[ConnectionDisconnectListener] ) extends Runnable with Logging { - private val metricsPackage = "kafka.server" + private val metricsPackage = "kafka.network" private val metricsClassName = "Processor" private val metricsGroup = new KafkaMetricsGroup(metricsPackage, metricsClassName) diff --git a/core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala b/core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala index 0c5eb83e5e97f..5577dc9bd38fd 100644 --- a/core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala +++ b/core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala @@ -1,7 +1,7 @@ /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with - * this work for additional information registryarding copyright ownership. + * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at