What is ListTransactions?
Finds potentially stuck or long-running transactions via kafka-transactions.sh --list. Filtering by duration threshold lets operators quickly identify transactions that have been open longer than expected and may be blocking read_committed consumers.
Wire Diagram
Response Header · flexible
message_size
int32 · 4B
correlation_id
int32 · 4B
tagged
var
ListTransactionsResponse v1
ThrottleTimeMs
int32 · 4B
ErrorCode
int16 · 2B
UnknownStateFilters
[]string
tagged
var
TransactionalId
string (compact)
ProducerId
int64 · 8B
TransactionState
string (compact)
tagged
var
Schema & Example
Schema { "ThrottleTimeMs": int32, "ErrorCode": int16, "UnknownStateFilters": [string], "TransactionStates": [{ "TransactionalId": string, "ProducerId": int64, "TransactionState": string }] }
Example { "ThrottleTimeMs": 0, "ErrorCode": 0, "UnknownStateFilters": ["Stable", "Empty"], "TransactionStates": [{ "TransactionalId": "tx-orders-001", "ProducerId": 0, "TransactionState": "CompleteCommit" }] }