KIP-1033 — Add Kafka Streams exception handler for exceptions occurring during processing
Accepted Kafka 3.9 Streams
KIP-1033 adds a `ProcessingExceptionHandler` interface to Kafka Streams (configured via `processing.exception.handler`) that intercepts uncaught exceptions thrown during `process()` calls in DSL or Processor API topologies, with built-in `LogAndFail` (default) and `LogAndContinue` implementations. Previously, unhandled processing exceptions terminated the `StreamThread`, requiring developers to wrap all processing logic in try-catch blocks—an error-prone approach that does not scale across large topologies.
Details
| Author | Damien Gasparina |
| Status | Accepted |
| Kafka Version | 3.9 |
| JIRA | KAFKA-16448 |
| Wiki | View on Apache Wiki |
| Created | 2024-03-29 |
| Last Modified | 2024-08-30 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.