Tommy Becker created KAFKA-16018:
------------------------------------
Summary: KafkaStreams can go into a zombie state if
UncaughtExceptionHandler is specified via the deprecated method
Key: KAFKA-16018
URL: https://issues.apache.org/jira/browse/KAFKA-16018
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 3.3.2
Reporter: Tommy Becker
We have a streams application in which all StreamThreads died due to a lack of
disk space. To our surprise, the KafkaStreams instance still reported its state
as running. Upon further investigation, it appears this is due to the
application setting an UncaughtExceptionHandler via the deprecated method (this
application was recently upgraded from 2.4.1):
[https://kafka.apache.org/33/javadoc/org/apache/kafka/streams/KafkaStreams.html#setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)]
The only way a StreamThread failure can cause the KafkaStreams instance to
transition to an error state now is via the new StreamsUncaughtExceptionHandler
machinery, but when an old UncaughtExceptionHandler is set by the old method
this code is effectively bypassed.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
