Method: Kafka::Protocol::TxnOffsetCommitRequest#initialize

Defined in:
lib/kafka/protocol/txn_offset_commit_request.rb

#initialize(transactional_id:, group_id:, producer_id:, producer_epoch:, offsets:) ⇒ TxnOffsetCommitRequest

Returns a new instance of TxnOffsetCommitRequest.



19
20
21
22
23
24
25
 
# File 'lib/kafka/protocol/txn_offset_commit_request.rb', line 19

def initialize(transactional_id:, group_id:, producer_id:, producer_epoch:, offsets:)
  @transactional_id = transactional_id
  @producer_id = producer_id
  @producer_epoch = producer_epoch
  @group_id = group_id
  @offsets = offsets
end