Kafka EndTxn Request Wire Format v0 — Binary Protocol Layout

What is EndTxn?

Commits or aborts a transaction (committed=true or false). If a producer crashes without calling EndTxn, the transaction coordinator aborts it after transaction.timeout.ms, blocking read_committed consumers on that partition until the abort marker is written.

Schema
{
  "TransactionalId": string,
  "ProducerId": int64,
  "ProducerEpoch": int16,
  "Committed": bool
}

Example
{
  "TransactionalId": "tx-orders-001",
  "ProducerId": 0,
  "ProducerEpoch": 12,
  "Committed": true
}