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_offsetObject (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_idObject (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