class Kafka::Protocol::AddOffsetsToTxnRequest
Public Class Methods
new(transactional_id: nil, producer_id:, producer_epoch:, group_id:)
click to toggle source
# File lib/kafka/protocol/add_offsets_to_txn_request.rb, line 6 def initialize(transactional_id: nil, producer_id:, producer_epoch:, group_id:) @transactional_id = transactional_id @producer_id = producer_id @producer_epoch = producer_epoch @group_id = group_id end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/add_offsets_to_txn_request.rb, line 13 def api_key ADD_OFFSETS_TO_TXN_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/add_offsets_to_txn_request.rb, line 21 def encode(encoder) encoder.write_string(@transactional_id.to_s) encoder.write_int64(@producer_id) encoder.write_int16(@producer_epoch) encoder.write_string(@group_id) end
response_class()
click to toggle source
# File lib/kafka/protocol/add_offsets_to_txn_request.rb, line 17 def response_class AddOffsetsToTxnResponse end