Method: Kafka::Protocol::EndTxnRequest#encode

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

#encode(encoder) ⇒ Object 



21
22
23
24
25
26
 
# 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