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 a9e529236fa MINOR: increase Config change throwable log info to error
(#14380)
a9e529236fa is described below
commit a9e529236fa54c07d48d38275bf9ab1124db072d
Author: NICOLAS GUYOMAR <[email protected]>
AuthorDate: Mon Sep 15 04:04:06 2025 +0200
MINOR: increase Config change throwable log info to error (#14380)
The ApiError.fromThrowable(t) is going to return a generic
Errors.UNKNOWN_SERVER_ERROR back to the calling client (CLI for
instance) (eg if the broker has an authZ issue with ZK) and such
UnknownServerException should have a matching ERROR level log in the
broker logs IHMO to make it easier to troubleshoot
Reviewers: Chia-Ping Tsai <[email protected]>
---
core/src/main/scala/kafka/server/ConfigAdminManager.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/kafka/server/ConfigAdminManager.scala
b/core/src/main/scala/kafka/server/ConfigAdminManager.scala
index 45a68d2d036..7394d2cfc43 100644
--- a/core/src/main/scala/kafka/server/ConfigAdminManager.scala
+++ b/core/src/main/scala/kafka/server/ConfigAdminManager.scala
@@ -151,7 +151,7 @@ class ConfigAdminManager(nodeId: Int,
} catch {
case t: Throwable =>
val err = ApiError.fromThrowable(t)
- info(s"Error preprocessing incrementalAlterConfigs request on
$configResource", t)
+ error(s"Error preprocessing incrementalAlterConfigs request on
$configResource", t)
results.put(resource, err)
}
}
@@ -252,7 +252,7 @@ class ConfigAdminManager(nodeId: Int,
} catch {
case t: Throwable =>
val err = ApiError.fromThrowable(t)
- info(s"Error preprocessing alterConfigs request on
$configResource: $err")
+ error(s"Error preprocessing alterConfigs request on
${configResource}: ${err}")
results.put(resource, err)
}
}