[jira] [Created] (KAFKA-15818) Implement max poll internval

["Philip Nee (Jira)" <ji...@apache.org>]

Philip Nee created KAFKA-15818:
----------------------------------

             Summary: Implement max poll internval
                 Key: KAFKA-15818
                 URL: https://issues.apache.org/jira/browse/KAFKA-15818
             Project: Kafka
          Issue Type: Task
          Components: consumer
            Reporter: Philip Nee


In the network thread, we need a timer configure to take MAX_POLL_INTERVAL_MAX.  The reason is if the user don't poll the consumer within the internal, the member needs to leave the group.

 

Currently, we send an acknowledgement event to the network thread per poll.  It needs to do two things 1. update autocommit state 2. update max poll interval timer 

 

The current logic looks like this:
{code:java}
 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.");
} {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)