conduktor.io ↗

KIP-210 — Provide for custom error handling when Kafka Streams fails to produce

Accepted Kafka 1.1 Streams

KIP-210 adds a `ProductionExceptionHandler` interface to Kafka Streams with a `handle(ProducerRecord, Exception)` method that returns `CONTINUE` or `FAIL`, plus a `default.production.exception.handler` Streams config to register it. Without this hook, any `ApiException` thrown when Streams writes to a downstream topic (e.g. due to a record exceeding `max.request.size`) tears down the entire `StreamThread`, requiring a manual restart.

Details

AuthorMatt Farmer
StatusAccepted
Kafka Version1.1
JIRAKAFKA-6086
WikiView on Apache Wiki
Created2017-10-18
Last Modified2018-06-13
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.