KIP-161 — streams deserialization exception handlers

Accepted Kafka 1.0 Streams

Introduces a DeserializationExceptionHandler SPI for Kafka Streams that lets users define custom behavior (log-and-continue or fail) when a record fails to deserialize. Without this, a single malformed record (poison pill) in a Streams input topic terminates the entire stream task, requiring manual offset manipulation or application code changes to skip bad records.

Details