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
| Author | Walker Carlson |
| Status | Accepted |
| Kafka Version | 2.8 |
| JIRA | KAFKA-9331 |
| Wiki | View on Apache Wiki |
| Created | 2020-09-11 |
| Last Modified | 2020-12-04 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.