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.
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
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] }] }