vvcephei opened a new pull request #9616: URL: https://github.com/apache/kafka/pull/9616
POC for: https://issues.apache.org/jira/browse/KAFKA-10091 https://cwiki.apache.org/confluence/x/JSXZCQ Please don't bother reviewing this. I did enough of the implementation to convince myself that the proposal will work. But the exact logic of resetting our internal flag isn't right, and I also didn't fix the unit tests to account for the new behavior. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) ---------------------------------------------------------------- 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
