Hi Kafka Devs! I’ve completely re-worked KIP-1097 in response to the earlier feedback.
Instead of an *Error Record Reporter*, the new draft proposes a pluggable *ErrorHandler* -mirroring *ProcessingExceptionHandler* in Kafka Streams. - Updated KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1097%3A+Add+Kafka+Connect+exception+handler - POC branch: https://github.com/anton-liauchuk/kafka/pull/1/files *What changed since the first draft* 1. *API* – new `*ErrorHandler*` interface with `*ErrorResponse {DROP, FAIL, ACK}*` (inspired by ` *org.apache.kafka.streams.errors.ProcessingExceptionHandler*`) 2. *Config* – introduces `*errors.tolerance=custom*` and ` *errors.handler.class*` 3. *Reporter vs Handler* – the separate **reporter** concept is removed; *Why it matters* A pluggable handler gives finer-grained error handling than ` *errors.tolerance*` (`none` / `all`) provides. Thanks in advance for your feedback!
