Implement max poll interval

 if (heartbeat.pollTimeoutExpired(now)) {
    // the poll timeout has expired, which means that the foreground thread has stalled
    // in between calls to poll().
    log.warn("consumer poll timeout has expired. This means the time between subsequent calls to poll() " +
        "was longer than the configured max.poll.interval.ms, which typically implies that " +
        "the poll loop is spending too much time processing messages. You can address this " +
        "either by increasing max.poll.interval.ms or by reducing the maximum size of batches " +
        "returned in poll() with max.poll.records.");

    maybeLeaveGroup("consumer poll timeout has expired.");
}