conduktor.io ↗

KIP-783 — Add TaskId field to StreamsException

Accepted Kafka 3.1 Streams

Standardizes exception handling in Kafka Streams by ensuring all exceptions propagated to the `StreamsUncaughtExceptionHandler` are consistently wrapped as `StreamsException` with a well-defined subtype hierarchy. Previously only some exceptions were wrapped, making it impossible to write reliable handler logic or reason about the type of failure.

Details

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version3.1
JIRAKAFKA-13381
WikiView on Apache Wiki
Created2021-10-18
Last Modified2021-10-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.