1// AddOffsetsToTxnRequest is a request that ties produced records to what group
2// is being consumed for the transaction.
3//
4// This request must be called before TxnOffsetCommitRequest.
5//
6// Internally, this request simply adds the __consumer_offsets topic as a
7// partition for this transaction with AddPartitionsToTxn for the partition
8// in that topic that contains the group.
9AddOffsetsToTxnRequest => key 25, max version 3, flexible v3+, txn coordinator
10 // TransactionalID is the transactional ID to use for this request.
11 TransactionalID: string
12 // ProducerID is the producer ID of the client for this transactional ID
13 // as received from InitProducerID.
14 ProducerID: int64
15 // ProducerEpoch is the producer epoch of the client for this transactional ID
16 // as received from InitProducerID.
17 ProducerEpoch: int16
18 // Group is the group to tie this transaction to.
19 Group: string
20
21// AddOffsetsToTxnResponse is a response to an AddOffsetsToTxnRequest.
22AddOffsetsToTxnResponse =>
23 ThrottleMillis(1)
24 // ErrorCode is any error for this topic/partition commit.
25 //
26 // TRANSACTIONAL_ID_AUTHORIZATION_FAILED is returned if the client is
27 // not authorized for write with transactional IDs with the requested
28 // transactional ID.
29 //
30 // GROUP_AUTHORIZATION_FAILED is returned if the client is not authorized
31 // to read group with the requested group id.
32 //
33 // This also can return any error that AddPartitionsToTxn returns.
34 ErrorCode: int16
View as plain text