conduktor.io ↗

KIP-1348 — Complete Kafka Streams Built-in Exception Handler Symmetry with LogAndContinueProductionExceptionHandler

Discussion Streams

Adds a built-in LogAndContinueProductionExceptionHandler to Kafka Streams that logs production and serialization failures, optionally routes the record to the configured DLQ topic, and continues processing. Streams ships log-and-continue handlers for deserialization and processing errors but only DefaultProductionExceptionHandler for production errors, which always fails, so a single unserializable output record creates a crash loop on every restart unless users write a custom handler.

Details

AuthorAnkur Sinha
StatusDiscussion
JIRAKAFKA-20604
WikiView on Apache Wiki
Created2026-05-20
Last Modified2026-06-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.