conduktor.io ↗

Kafka DescribeProducers Request Wire Format v0 — Binary Protocol Layout

What is DescribeProducers?

Shows active producer sessions on a partition via kafka-transactions.sh --describe-producers, including producer ID, epoch, and last sequence number. Helps diagnose zombie producers (old producer ID still active) or duplicate sequence errors.

Related Errors

TOPIC_AUTHORIZATION_FAILED · UNKNOWN_TOPIC_OR_PARTITION

Wire Diagram

Request Header · flexible
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string (compact)
tagged var
DescribeProducersRequest v0
Topics array
tagged var
Name string (compact)
PartitionIndexes []int32
tagged var

Schema & Example

Schema
{
  "Topics": [{
      "Name": string,
      "PartitionIndexes": [int32]
  }]
}
Example
{
  "Topics": [{
      "Name": "orders",
      "PartitionIndexes": [1, 2, 3]
  }]
}