class Kafka::Protocol::FetchResponse::FetchedPartition

Attributes

aborted_transactions[R]
error_code[R]
highwater_mark_offset[R]
last_stable_offset[R]
messages[R]
partition[R]

Public Class Methods

new(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:) click to toggle source
# 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