conduktor.io ↗

Kafka DescribeTransactions Changelog — Protocol Version History

What is DescribeTransactions?

Returns the state of specific transactions via kafka-transactions.sh --describe. A transaction stuck in ONGOING state beyond its timeout is either a zombie producer that crashed mid-transaction or a slow producer still committing; read_committed consumers are blocked until it resolves.

VersionKafkaChanges
DescribeTransactionsRequest
v03.0
+ TransactionalIds []string
~ Flexible encoding enabled FLEXIBLE
DescribeTransactionsResponse
v03.0
+ ThrottleTimeMs int32
+ TransactionStates []TransactionState
+ ErrorCode int16
+ TransactionalId string
+ TransactionState string
+ TransactionTimeoutMs int32
+ TransactionStartTimeMs int64
+ ProducerId int64
+ ProducerEpoch int16
+ Topics []TopicData
+ Topic string
+ Partitions []int32
~ Flexible encoding enabled FLEXIBLE