KIP-1158 — Improve Connect SourceTask commit()

Discussion Connect

Proposes extending SourceTask with a commit(Map offsets) hook that receives the specific offsets being committed, enabling source connectors to know exactly which records are durably committed to Kafka before signaling progress to the external source system. The existing commit() hook fires periodically but without the committed offset values, and commitRecord() fires per-record but without strict ordering guarantees or batch-level completion signals.

Details