This is an automated email from the ASF dual-hosted git repository.
soarez 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 25f9b1ee4c2 MINOR: ShutdownableThread: log on error level on
FatalExitError (#19351)
25f9b1ee4c2 is described below
commit 25f9b1ee4c2e330b589698d98040e9761e1dc6ab
Author: Gaurav Narula <[email protected]>
AuthorDate: Fri Apr 4 15:38:45 2025 +0100
MINOR: ShutdownableThread: log on error level on FatalExitError (#19351)
This will help debugging the error as the stacktrace is valuable in
identifying the origin.
Reviewers: TaiJuWu <[email protected]>, Igor Soarez <[email protected]>, Ken
Huang <[email protected]>
---
.../src/main/java/org/apache/kafka/server/util/ShutdownableThread.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java
b/server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java
index 7d18975b6cd..139c3496a8c 100644
---
a/server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java
+++
b/server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java
@@ -137,7 +137,7 @@ public abstract class ShutdownableThread extends Thread {
} catch (FatalExitError e) {
shutdownInitiated.countDown();
shutdownComplete.countDown();
- log.info("Stopped");
+ log.error("Stopped due to fatal error with exit code {}",
e.statusCode(), e);
Exit.exit(e.statusCode());
} catch (Throwable e) {
if (isRunning())
