Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗
KIPs / KIP-1228

KIP-1228 — Add Transaction Version to WriteTxnMarkersRequest

Accepted Kafka 4.2 TransactionsProtocol

Adds a transactionVersion field to WriteTxnMarkersRequest so that partition leaders can validate Transaction Version 2 (TV2) end markers by requiring producerEpoch > currentEpoch instead of accepting equality. Without this, leaders could not distinguish late/duplicate TV1 markers from active TV2 transaction markers, creating a correctness gap in exactly-once semantics even after KIP-890 introduced epoch-bump semantics.

Protocol Impact

WriteTxnMarkers v2 · ApiVersions · EndTxn

Details

AuthorRitika Reddy
StatusAccepted
Kafka Version4.2
JIRAKAFKA-19446
WikiView on Apache Wiki
Created2025-10-13
Last Modified2025-10-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.