conduktor.io ↗

KIP-254 — JsonConverter Exception Handeling

Discussion Kafka 2.0 Connect

KIP-254 proposes adding a configurable error handler to `JsonConverter` in Kafka Connect so that individual malformed JSON messages can be skipped or dead-lettered rather than crashing the task. A single unparseable JSON record in an input topic causes the entire Connect task to fail and enter a restart loop, blocking all subsequent records.

Details

AuthorPrasanna Subburaj
StatusDiscussion
Kafka Version2.0
JIRAKAFKA-6490
WikiView on Apache Wiki
Created2018-02-12
Last Modified2018-02-12
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.