You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Tommy Becker (Jira)" <ji...@apache.org> on 2023/12/15 17:48:00 UTC

[jira] [Created] (KAFKA-16018) KafkaStreams can go into a zombie state if UncaughtExceptionHandler is specified via the deprecated method

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)