Kafka TxnOffsetCommit Response Wire Format v0

What is TxnOffsetCommit?

Stages an offset commit as part of a transaction. The offsets aren't visible to other consumers until the transaction commits. If the transaction aborts, the offsets roll back and the consumer will reprocess those records.

Wire Diagram

Response Header

message_size int32 · 4B

correlation_id int32 · 4B

TxnOffsetCommitResponse v0

ThrottleTimeMs int32 · 4B

Topics array

Name string

Partitions array

PartitionIndex int32 · 4B

ErrorCode int16 · 2B

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "Topics": [{
      "Name": string,
      "Partitions": [{
          "PartitionIndex": int32,
          "ErrorCode": int16
      }]
  }]
}

Example
{
  "ThrottleTimeMs": 0,
  "Topics": [{
      "Name": "orders",
      "Partitions": [{
          "PartitionIndex": 3,
          "ErrorCode": 0
      }]
  }]
}

Kafka TxnOffsetCommit Response Wire Format v0 — Binary Protocol Layout

What is TxnOffsetCommit?

Wire Diagram

Schema & Example