(kafka) branch trunk updated: MINOR: Fix the incorrect package name in the metrics and a typo (#20666)

[ch...@apache.org]

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

chia7712 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 9d319283c12 MINOR: Fix the incorrect package name in the metrics and a typo (#20666)
9d319283c12 is described below

commit 9d319283c12f79e353bd45c42c637c9517ac546e
Author: Xuan-Zhang Gong <go...@gmail.com>
AuthorDate: Thu Oct 9 20:17:27 2025 +0800

    MINOR: Fix the incorrect package name in the metrics and a typo (#20666)
    
    Fix the incorrect package name in metrics and revert the comment
    
    see:   https://github.com/apache/kafka/pull/20399#discussion_r2415673042
    https://github.com/apache/kafka/pull/20399#discussion_r2415633676
    
    Reviewers: Ken Huang <s7...@gmail.com>, Manikumar Reddy
     <ma...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>
---
 core/src/main/scala/kafka/network/SocketServer.scala                   | 2 +-
 core/src/test/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 c14c5c665af..306b633f6fa 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 0c5eb83e5e9..5577dc9bd38 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