All, I'd like to start a discussion on adding ways to handle and report record processing errors in Connect. Please find a KIP here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-298%3A+Error+Handling+in+Connect Any feedback will be highly appreciated. Thanks very much, Arjun