search

llofberg / kafka-connect-rest

Kafka Connect REST connector
Apache License 2.0
109 stars 54 forks source link

DLQ support for Error records #34

Open kusum007 opened 4 years ago

kusum007 commented 4 years ago

Unlike in Transformation stage, Connect framework doesn't support pushing RetriableException from the connector put method to deadletter queue. The proposed solution allows the RestSinkTask to push the error records to the DLQ topic configured.