philipnee opened a new pull request, #14873: URL: https://github.com/apache/kafka/pull/14873
Currently, poll interval is not being respected during consumer#poll. We need to make sure the consumer can leave the group actively when the user doesn't poll frequently enough. This PR added 1. a poll timer and 2. a boolean flag notifying joining on subsequent poll. - The poll timer is always configured with rebalanceTimeout - The boolean flag, rejoinOnPoll, is set when the leaveGroup completes. Such as the subsequent poll and rejoin. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
