-
Type:
Improvement
-
Status: Resolved
-
Priority:
Critical
-
Resolution: Fixed
-
Affects Version/s: 2.6.0
-
Fix Version/s: 2.6.0
-
Component/s: KafkaConnect
-
Labels:None
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.
- 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
-
- links to