Hi all, I know it's a busy time with the upcoming 2.6 release and I don't expect this to get a lot of traction until that's done, but I've published a KIP for allowing atomic commit of offsets and records for source connectors and would appreciate your feedback: https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Atomic+commit+of+source+connector+records+and+offsets
This feature should make it possible to implement source connectors with exactly-once delivery guarantees, and even allow a wide range of existing source connectors to provide exactly-once delivery guarantees with no changes required. Cheers, Chris
