What is WriteTxnMarkers?
After EndTxn, the transaction coordinator sends this internally (never user code) to write COMMIT or ABORT markers to every partition in the transaction. Consumers in read_committed mode are unblocked partition-by-partition as markers arrive, so a slow partition can delay consumption even if all others are done.
| Version | Kafka | Changes |
|---|---|---|
| WriteTxnMarkersRequest | ||
| v1 | 2.8 | ~ Flexible encoding enabled FLEXIBLE enables flexible versions. |
| v2 | 4.2 | + TransactionVersion int8adds TransactionVersion field to the WritableTxnMarker (KIP-1228). |
| WriteTxnMarkersResponse | ||
| v1 | 2.8 | ~ Flexible encoding enabled FLEXIBLE enables flexible versions. |
| v2 | 4.2 | matches WriteTxnMarkersRequest version 2 (KIP-1228). |