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.
| Version | Kafka | Changes |
|---|---|---|
| DescribeProducersRequest | ||
| v0 | 2.8 | + Topics []TopicRequest+ Name string+ PartitionIndexes []int32~ Flexible encoding enabled FLEXIBLE |
| DescribeProducersResponse | ||
| v0 | 2.8 | + ThrottleTimeMs int32+ Topics []TopicResponse+ Name string+ Partitions []PartitionResponse+ PartitionIndex int32+ ErrorCode int16+ ErrorMessage string+ ActiveProducers []ProducerState+ ProducerId int64+ ProducerEpoch int32+ LastSequence int32+ LastTimestamp int64+ CoordinatorEpoch int32+ CurrentTxnStartOffset int64~ Flexible encoding enabled FLEXIBLE |