conduktor.io ↗

KIP-610 — Error Reporting in Sink Connectors

Accepted Kafka 2.6 Connect

Extends Kafka Connect's dead letter queue (DLQ) error reporting to cover failures that occur within `SinkTask.put()` in addition to the existing coverage for SMT and converter failures. The KIP-298 DLQ mechanism only captured errors in the transform and converter phases; once a record was handed to the connector's `put()` method, errors had no DLQ path and were simply logged or caused task failure.

Details

AuthorAakash Shah
StatusAccepted
Kafka Version2.6
JIRAKAFKA-9971
WikiView on Apache Wiki
Created2020-05-06
Last Modified2020-06-18
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.