Class: Kafka::Protocol::FetchResponse::FetchedPartition

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:) ⇒ FetchedPartition

Returns a new instance of FetchedPartition.



34
35
36
37
38
39
40
41
 
# File 'lib/kafka/protocol/fetch_response.rb', line 34

def initialize(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:)
  @partition = partition
  @error_code = error_code
  @highwater_mark_offset = highwater_mark_offset
  @messages = messages
  @last_stable_offset = last_stable_offset
  @aborted_transactions = aborted_transactions
end

Instance Attribute Details

#aborted_transactions ⇒ Object (readonly)

Returns the value of attribute aborted_transactions.



32
33
34
 
# File 'lib/kafka/protocol/fetch_response.rb', line 32

def aborted_transactions
  @aborted_transactions
end

#error_code ⇒ Object (readonly)

Returns the value of attribute error_code.



31
32
33
 
# File 'lib/kafka/protocol/fetch_response.rb', line 31

def error_code
  @error_code
end

#highwater_mark_offset ⇒ Object (readonly)

Returns the value of attribute highwater_mark_offset.



32
33
34
 
# File 'lib/kafka/protocol/fetch_response.rb', line 32

def highwater_mark_offset
  @highwater_mark_offset
end

#last_stable_offset ⇒ Object (readonly)

Returns the value of attribute last_stable_offset.



32
33
34
 
# File 'lib/kafka/protocol/fetch_response.rb', line 32

def last_stable_offset
  @last_stable_offset
end

#messages ⇒ Object (readonly)

Returns the value of attribute messages.



32
33
34
 
# File 'lib/kafka/protocol/fetch_response.rb', line 32

def messages
  @messages
end

#partition ⇒ Object (readonly)

Returns the value of attribute partition.



31
32
33
 
# File 'lib/kafka/protocol/fetch_response.rb', line 31

def partition
  @partition
end