This is an automated email from the ASF dual-hosted git repository.
guozhang 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 58402a6 MINOR: add helpful error message (#11139)
58402a6 is described below
commit 58402a6fe8ff0b395ef5d28008a58f15db8c270d
Author: Walker Carlson <[email protected]>
AuthorDate: Wed Jul 28 13:38:31 2021 -0500
MINOR: add helpful error message (#11139)
I noticed that replace thread actions would not be logged unless the user
added a log in the handler. I think it would be very useful for debugging.
Reviewers: Guozhang Wang <[email protected]>
---
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
index 205e22f..326edc4 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -498,6 +498,7 @@ public class KafkaStreams implements AutoCloseable {
}
switch (action) {
case REPLACE_THREAD:
+ log.error("Replacing thread in the streams uncaught exception
handler", throwable);
replaceStreamThread(throwable);
break;
case SHUTDOWN_CLIENT:
