KIP-1097 — Add Kafka Connect exception handler

Discussion Connect

Proposes a pluggable ErrorHandler interface for Kafka Connect that allows connector developers to define custom per-record error handling logic (DROP, FAIL, ACK) during specific processing stages. Connect's existing error tolerance (none/all) and dead letter queue were coarse-grained, with no way to implement stage-specific or record-specific handling logic comparable to Kafka Streams' ProcessingExceptionHandler.

Details