Hi all, I'd like to resurface KIP-618, which has been expanded from its previous form ("Atomic commit of source connector records and offsets") to something more general and, hopefully, more powerful: exactly-once support for source connectors (including fencing-out of zombie tasks). Would appreciate your thoughts!
https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors Cheers, Chris