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.
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
DescribeTransactionsRequest v0
TransactionalIds
[]string
tagged
var
Schema & Example
Schema { "TransactionalIds": [string] }
Example { "TransactionalIds": ["value-1", "value-2"] }