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 <[email protected]>
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 <[email protected]>, Manikumar Reddy
<[email protected]>, Chia-Ping Tsai <[email protected]>
---
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
