Method: Kafka::FetchedBatch#first_offset

Defined in:
lib/kafka/fetched_batch.rb

#first_offsetObject



42
43
44
45
46
47
48
# File 'lib/kafka/fetched_batch.rb', line 42

def first_offset
  if empty?
    nil
  else
    messages.first.offset
  end
end