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
| Author | Matt Farmer |
| Status | Accepted |
| Kafka Version | 1.1 |
| JIRA | KAFKA-6086 |
| Wiki | View on Apache Wiki |
| Created | 2017-10-18 |
| Last Modified | 2018-06-13 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.