KIP-1289 — Support Transactional Acknowledgments for Share Groups

Discussion ConsumerTransactions

Adds transactional acknowledgment support for share group consumers, ensuring that a record's side-effect writes and its share group acknowledgment are committed atomically within a single Kafka transaction. Without this, a framework processing share group records can produce output and then fail before acknowledging, causing re-delivery and double-processing with no EOS guarantee.

Protocol Impact

Produce · OffsetCommit · AddOffsetsToTxn · EndTxn · TxnOffsetCommit · ShareAcknowledge

Details