Description
Currently, KIP-298 provides error handling in Kafka Connect that includes functionality such as retrying, logging, and sending errant records to a dead letter queue. However, the dead letter queue functionality from KIP-298 only supports error reporting within contexts of the transform operation, and key, value, and header converter operation. Within the context of the put(...) method in sink connectors, there is no support for dead letter queue/error reporting functionality.
Attachments
Issue Links
- is duplicated by
-
KAFKA-9314 Connect put() and poll() retries not conforming to KIP-298
- Resolved
- is related to
-
KAFKA-10111 SinkTaskContext.errantRecordReporter() added in KIP-610 should be a default method
- Resolved
-
KAFKA-9314 Connect put() and poll() retries not conforming to KIP-298
- Resolved
-
KAFKA-10115 Incorporate errors.tolerance with the Errant Record Reporter
- Resolved
- supercedes
-
KAFKA-8597 Give access to the Dead Letter Queue APIs to Kafka Connect Developers
- Resolved
- links to