Method: Kafka::FetchedBatch#initialize

Defined in:
lib/kafka/fetched_batch.rb

#initialize(topic:, partition:, highwater_mark_offset:, messages:, last_offset: nil, leader_epoch: nil) ⇒ FetchedBatch

Returns a new instance of FetchedBatch.



25
26
27
28
29
30
31
32
 
# File 'lib/kafka/fetched_batch.rb', line 25

def initialize(topic:, partition:, highwater_mark_offset:, messages:, last_offset: nil, leader_epoch: nil)
  @topic = topic
  @partition = partition
  @highwater_mark_offset = highwater_mark_offset
  @messages = messages
  @last_offset = last_offset
  @leader_epoch = leader_epoch
end