ableegoldman commented on pull request #10986: URL: https://github.com/apache/kafka/pull/10986#issuecomment-878706682
@hachikuji in the EAGER case, after the first `onJoinPrepare` / `onPartitionsRevoked`, the subscription would have been cleared. So any subsequent invocations of `onPartitionsRevoked` would be with an empty set of partitions @everyone, I was having trouble getting a unit test that would actually verify this behavior but I wanted to kick off discussion on the fix ASAP (for obvious reasons) so I opened the PR without one. I do intended to add a test, I just haven't had time to pursue that yet. Suggestions welcome :P -- 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