class Kafka::Protocol::EndTxnRequest
Public Class Methods
new(transactional_id:, producer_id:, producer_epoch:, transaction_result:)
click to toggle source
# File lib/kafka/protocol/end_txn_request.rb, line 6 def initialize(transactional_id:, producer_id:, producer_epoch:, transaction_result:) @transactional_id = transactional_id @producer_id = producer_id @producer_epoch = producer_epoch @transaction_result = transaction_result end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/end_txn_request.rb, line 13 def api_key END_TXN_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/end_txn_request.rb, line 21 def encode(encoder) encoder.write_string(@transactional_id) encoder.write_int64(@producer_id) encoder.write_int16(@producer_epoch) encoder.write_boolean(@transaction_result) end
response_class()
click to toggle source
# File lib/kafka/protocol/end_txn_request.rb, line 17 def response_class EndTxnResposne end