1// For KIP-664, DescribeTransactionsRequest describes the state of transactions.
2DescribeTransactionsRequest => key 65, max version 0, flexible v0+
3 // Array of transactionalIds to include in describe results. If empty, then
4 // no results will be returned.
5 TransactionalIDs: [string]
6
7// DescribeTransactionsResponse is a response to a DescribeTransactionsRequest.
8DescribeTransactionsResponse =>
9 ThrottleMillis
10 TransactionStates: [=>]
11 // A potential error code for describing this transaction.
12 //
13 // NOT_COORDINATOR is returned if the broker receiving this transactional
14 // ID does not own the ID.
15 //
16 // COORDINATOR_LOAD_IN_PROGRESS is returned if the coordiantor is laoding.
17 //
18 // COORDINATOR_NOT_AVAILABLE is returned if the coordinator is being shutdown.
19 //
20 // TRANSACTIONAL_ID_NOT_FOUND is returned if the transactional ID could not be found.
21 //
22 // TRANSACTIONAL_ID_AUTHORIZATION_FAILED is returned if the user does not have
23 // Describe permissions on the transactional ID.
24 ErrorCode: int16
25 // TransactionalID is the transactional ID this record is for.
26 TransactionalID: string
27 // State is the state the transaction is in.
28 State: string
29 // TimeoutMillis is the timeout of this transaction in milliseconds.
30 TimeoutMillis: int32
31 // StartTimestamp is the timestamp in millis of when this transaction started.
32 StartTimestamp: int64
33 // ProducerID is the ID in use by the transactional ID.
34 ProducerID: int64
35 // ProducerEpoch is the epoch associated with the producer ID.
36 ProducerEpoch: int16
37 // The set of partitions included in the current transaction (if active).
38 // When a transaction is preparing to commit or abort, this will include
39 // only partitions which do not have markers.
40 //
41 // This does not include topics the user is not authorized to describe.
42 Topics: [=>]
43 Topic: string
44 Partitions: [int32]
View as plain text