conduktor.io ↗

KIP-671 — Introduce Kafka Streams Specific Uncaught Exception Handler

Accepted Kafka 2.8 Streams

Introduces a Kafka Streams-specific `StreamsUncaughtExceptionHandler` that receives uncaught exceptions from stream threads and returns one of `SHUTDOWN_STREAM_THREAD`, `REPLACE_STREAM_THREAD`, or `SHUTDOWN_CLIENT` to control recovery behavior. The existing Java `UncaughtExceptionHandler` fires after the thread is already dead, preventing in-thread recovery actions like graceful shutdown or thread replacement.

Details

AuthorWalker Carlson
StatusAccepted
Kafka Version2.8
JIRAKAFKA-9331
WikiView on Apache Wiki
Created2020-09-11
Last Modified2020-12-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.