class Kafka::OffsetManager
def commit_timeout_reached?
def commit_timeout_reached? @commit_interval != 0 && seconds_since_last_commit >= @commit_interval end
def commit_timeout_reached? @commit_interval != 0 && seconds_since_last_commit >= @commit_interval end