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
| Author | Nicholas Telford |
| Status | Discussion |
| JIRA | KAFKA-15600 |
| Wiki | View on Apache Wiki |
| Created | 2023-10-12 |
| Last Modified | 2023-10-26 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.