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)
