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

Kafka AddPartitionsToTxn Response Wire Format v2 — Binary Protocol Layout

What is AddPartitionsToTxn?

Transactional producers send this before writing to any new partition within a transaction to register it with the coordinator. CONCURRENT_TRANSACTIONS means another producer with the same transactional.id is still active and must complete or time out first.

Related Errors

CONCURRENT_TRANSACTIONS · COORDINATOR_NOT_AVAILABLE · INVALID_PRODUCER_EPOCH · INVALID_PRODUCER_ID_MAPPING · INVALID_REQUEST · INVALID_TRANSACTION_TIMEOUT · INVALID_TXN_STATE · NOT_COORDINATOR · OPERATION_NOT_ATTEMPTED · PRODUCER_FENCED · TOPIC_AUTHORIZATION_FAILED · TRANSACTIONAL_ID_AUTHORIZATION_FAILED · TRANSACTIONAL_ID_NOT_FOUND · TRANSACTION_ABORTABLE · UNKNOWN_TOPIC_OR_PARTITION · UNSUPPORTED_VERSION

Wire Diagram

Response Header
message_size int32 · 4B
correlation_id int32 · 4B
AddPartitionsToTxnResponse v2
ThrottleTimeMs int32 · 4B
ResultsByTopicV3AndBelow array
Name string
ResultsByPartition array
PartitionIndex int32 · 4B
PartitionErrorCode int16 · 2B

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "ResultsByTopicV3AndBelow": [{
      "Name": string,
      "ResultsByPartition": [{
          "PartitionIndex": int32,
          "PartitionErrorCode": int16
      }]
  }]
}
Example
{
  "ThrottleTimeMs": 0,
  "ResultsByTopicV3AndBelow": [{
      "Name": "orders",
      "ResultsByPartition": [{
          "PartitionIndex": 3,
          "PartitionErrorCode": 1
      }]
  }]
}