KIP-672 — Introduce Kafka Streams Specific Uncaught Exception Handler

Discussion Streams

Introduces a `KafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)` API that lets users return a `StreamThreadExceptionResponse` enum value (`SHUTDOWN_STREAM_THREAD`, `REPLACE_STREAM_THREAD`, `SHUTDOWN_CLIENT`) in response to stream thread exceptions. The default Java `UncaughtExceptionHandler` fires post-mortem after the thread is already dead, making it impossible to replace the thread or cleanly shut down Streams before resources are corrupted.

Details