Method: Kafka::Protocol::FetchResponse::AbortedTransaction#initialize

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

#initialize(producer_id:, first_offset:) ⇒ AbortedTransaction

Returns a new instance of AbortedTransaction.



56
57
58
59
 
# File 'lib/kafka/protocol/fetch_response.rb', line 56

def initialize(producer_id:, first_offset:)
  @producer_id = producer_id
  @first_offset = first_offset
end