Hi all, I would like to discuss KIP-1158. This KIP introduces a new "commit()" method in KafkaConnect SourceTask interface, primarily for use-cases where SourceConnectors need to track "source-offset" commits.
Thanks in advance for reviewing ! KIP : https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=347933317 Thanks, Sudesh
