class Kafka::OffsetManager

def commit_offsets_if_necessary

Returns:
  • (nil) - 
def commit_offsets_if_necessary
  recommit = recommit_timeout_reached?
  if recommit || commit_timeout_reached? || commit_threshold_reached?
    commit_offsets(recommit)
  end
end