Hello all, I've created a KIP to handle error reporting for records in sink connectors, specifically within the context of put(...):
https://cwiki.apache.org/confluence/display/KAFKA/KIP-610%3A+Error+Reporting+in+Sink+Connectors I would appreciate any kind of feedback. Thanks, Aakash
