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
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
ListTransactionsRequest v0
StateFilters
[]string
ProducerIdFilters
[]int64
tagged
var
Schema & Example
Schema { "StateFilters": [string], "ProducerIdFilters": [int64] }
Example { "StateFilters": ["Stable", "Empty"], "ProducerIdFilters": [1000, 2000] }