Method: Kafka::FetchedBatch#offset_lag

Defined in:
lib/kafka/fetched_batch.rb

#offset_lag ⇒ Object 



50
51
52
53
54
55
56
 
# File 'lib/kafka/fetched_batch.rb', line 50

def offset_lag
  if empty?
    0
  else
    (highwater_mark_offset - 1) - last_offset
  end
end