protected void handlePollTimeoutExpiry() {
        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.");
    }
@throws KafkaException if the rebalance callback throws exception
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java