Mikołaj Bul created KAFKA-19724:
-----------------------------------
Summary: Global stream thread ignores all exceptions
Key: KAFKA-19724
URL: https://issues.apache.org/jira/browse/KAFKA-19724
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 3.4.0
Reporter: Mikołaj Bul
{{globalStreamThread}} in {{KafkaStreams}} class ignores all exceptions and
fails to apply the user-provided {{StreamsUncaughtExceptionHandler}} in:
{code:java}
public void setUncaughtExceptionHandler(final StreamsUncaughtExceptionHandler
userStreamsUncaughtExceptionHandler)
{code}
This can lead to streams being stuck in faulty state after an exception is
thrown during their initialization phase (e.g. failure to load the RocksDB
native library).
>From my understanding of the {{b62d8b97}} commit message, the following code
>is unnecessary as the {{globalStreamThread}} can't be replaced and issue
>description from KAFKA-12699 doesn't apply to it. Removing it should help.
{code:java}
if (globalStreamThread != null) {
globalStreamThread.setUncaughtExceptionHandler((t, e) -> { }
);
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
