Class: Kafka::Protocol::FetchResponse::AbortedTransaction

Inherits:
Object
  • Object
show all
Defined in:
lib/kafka/protocol/fetch_response.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#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

Instance Attribute Details

#first_offset ⇒ Object (readonly)

Returns the value of attribute first_offset.



54
55
56
 
# File 'lib/kafka/protocol/fetch_response.rb', line 54

def first_offset
  @first_offset
end

#producer_id ⇒ Object (readonly)

Returns the value of attribute producer_id.



54
55
56
 
# File 'lib/kafka/protocol/fetch_response.rb', line 54

def producer_id
  @producer_id
end