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)
         }
       }

Reply via email to