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:, messages:) ⇒ FetchedPartition

Returns a new instance of FetchedPartition.


22
23
24
25
26
27
# File 'lib/kafka/protocol/fetch_response.rb', line 22

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

Instance Attribute Details

#error_codeObject (readonly)

Returns the value of attribute error_code


19
20
21
# File 'lib/kafka/protocol/fetch_response.rb', line 19

def error_code
  @error_code
end

#highwater_mark_offsetObject (readonly)

Returns the value of attribute highwater_mark_offset


20
21
22
# File 'lib/kafka/protocol/fetch_response.rb', line 20

def highwater_mark_offset
  @highwater_mark_offset
end

#messagesObject (readonly)

Returns the value of attribute messages


20
21
22
# File 'lib/kafka/protocol/fetch_response.rb', line 20

def messages
  @messages
end

#partitionObject (readonly)

Returns the value of attribute partition


19
20
21
# File 'lib/kafka/protocol/fetch_response.rb', line 19

def partition
  @partition
end