Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗
KIPs / KIP-298

KIP-298 — Error Handling in Connect

Accepted Kafka 2.0 Connect

KIP-298 adds configurable error handling to Kafka Connect covering deserialization errors, transformation failures, and sink write failures, with options to log, skip (dead-letter queue), or fail on each error type. Before this change, any record-level error causes the entire task to fail and restart, providing no way to skip or quarantine bad records.

Details

AuthorArjun Satish
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6738
WikiView on Apache Wiki
Created2018-05-08
Last Modified2019-04-28
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.