1// Introduced for KIP-664, DescribeProducersRequest allows for introspecting
2// the state of the transaction coordinator. This request can be used to detect
3// hanging transactions or other EOS-related problems.
4//
5// This request allows for describing the state of the active
6// idempotent/transactional producers.
7DescribeProducersRequest => key 61, max version 0, flexible v0+
8 // The topics to describe producers for.
9 Topics: [=>]
10 Topic: string
11 // The partitions to list producers for for the given topic.
12 Partitions: [int32]
13
14// DescribeProducersResponse is a response to a DescribeProducersRequest.
15DescribeProducersResponse =>
16 ThrottleMillis
17 Topics: [=>]
18 Topic: string
19 Partitions: [=>]
20 Partition: int32
21 // The partition error code, or 0 if there was no error.
22 //
23 // NOT_LEADER_OR_FOLLOWER is returned if the broker receiving this request
24 // is not the leader of the partition.
25 //
26 // TOPIC_AUTHORIZATION_FAILED is returned if the user does not have Describe
27 // permissions on the topic.
28 //
29 // UNKNOWN_TOPIC_OR_PARTITION is returned if the partition is not known to exist.
30 //
31 // Other errors may be returned corresponding to the partition being offline, etc.
32 ErrorCode: int16
33 // The partition error message, which may be null if no additional details are available.
34 ErrorMessage: nullable-string
35 // The current idempotent or transactional producers producing to this partition,
36 // and the metadata related to their produce requests.
37 ActiveProducers: [=>]
38 ProducerID: int64
39 ProducerEpoch: int32
40 // The last sequence produced.
41 LastSequence: int32(-1)
42 // The last timestamp produced.
43 LastTimestamp: int64(-1)
44 // The epoch of the transactional coordinator for this last produce.
45 CoordinatorEpoch: int32
46 // The first offset of the transaction.
47 CurrentTxnStartOffset: int64(-1)
View as plain text