guozhangwang commented on pull request #8934: URL: https://github.com/apache/kafka/pull/8934#issuecomment-651409789
> Reading from the JIRA log, this seems not to be the full solution to the reported bug? Here's my reasoning: if there are still some owned partitions that are fetchable even during a rebalance, then within the while-loop even if we exit the `updateAssignmentMetadataIfNeeded` we can still try to fetch from then and then break out of the while loop. However, if we do not have fetchable partitions then we may be blocked in the while-loop for a long time until the poll timeout expires. Normally that should still be able to exit the busy while-loop eventually since the `timer.update` should still be called in `pollForFetches` within that while loop and hence advance the timer. It's indeed puzzling to me that why with cooperative rebalance, then we would block inside the while loop forever. I will post this to the JIRA and ask other folks. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
