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
| Author | Aakash Shah |
| Status | Accepted |
| Kafka Version | 2.6 |
| JIRA | KAFKA-9971 |
| Wiki | View on Apache Wiki |
| Created | 2020-05-06 |
| Last Modified | 2020-06-18 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.