KIP-618 — Exactly-Once Support for Source Connectors

Accepted Kafka 3.2 ConnectTransactions

Adds exactly-once delivery support for Kafka Connect source connectors by writing source records and their offsets atomically within a Kafka transaction, using the transactional producer API. Without EoS, source connector offsets are committed separately from the records they correspond to, creating a window where records can be duplicated on Connect worker restart.

Details