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 v1
StateFilters
[]string
ProducerIdFilters
[]int64
DurationFilter
int64 · 8B
tagged
var
Schema & Example
Schema { "StateFilters": [string], "ProducerIdFilters": [int64], "DurationFilter": int64 }
Example { "StateFilters": ["Stable", "Empty"], "ProducerIdFilters": [1000, 2000], "DurationFilter": 60000 }