conduktor.io ↗

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

AuthorDamien Gasparina
StatusAccepted
Kafka Version3.9
JIRAKAFKA-16448
WikiView on Apache Wiki
Created2024-03-29
Last Modified2024-08-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.