lianetm commented on code in PR #15909: URL: https://github.com/apache/kafka/pull/15909#discussion_r1596994382
########## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ########## @@ -255,11 +257,15 @@ public long maximumTimeToWait(long currentTimeMs) { * member to {@link MemberState#JOINING}, so that it rejoins the group. */ public void resetPollTimer(final long pollMs) { + pollTimer.update(pollMs); if (pollTimer.isExpired()) { - logger.debug("Poll timer has been reset after it had expired"); + logger.warn("Time between subsequent calls to poll() was longer than the configured" + + "max.poll.interval.ms, exceeded by %s ms. This typically implies that the " + Review Comment: yeap, my bad, I had found it too so it's fixed in a commit above -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org