Hi all, I created KIP-89 for making a Connect API change that allows for sink connectors to decouple flush and offset commits.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-89%3A+Allow+sink+connectors+to+decouple+flush+and+offset+commit I'd welcome your input. Best, Shikhar
