conduktor.io ↗

KIP-990 — Capability to PAUSE Tasks on DeserializationException

Discussion Streams

Adds a `PAUSE` return value to the Kafka Streams `DeserializationExceptionHandler` that suspends the affected task without killing the stream thread. The existing options are `FAIL` (crash the thread) or `CONTINUE` (skip and log), with no way to pause processing on a bad record until an operator intervenes.

Details

AuthorNicholas Telford
StatusDiscussion
JIRAKAFKA-15600
WikiView on Apache Wiki
Created2023-10-12
Last Modified2023-10-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.