zjncs opened a new pull request, #11020: URL: https://github.com/apache/rocketmq/pull/11020
## Which Issue(s) This PR Fixes Fixes #10987 ## Brief Description `ConsumerOffsetManager.queryMinOffsetInAllGroup` iterated the live `offsetTable.keySet()` view and removed matching groups while answering a correction-offset query. `Iterator.remove()` therefore permanently deleted consumer offsets as a read-side effect. Copy the key set before filtering so the query can continue to call `removeConsumerOffset` only for its intended correction workflow without mutating the live map through the iterator. ## How Did You Test This Change? - Base SHA: `$(git rev-parse develop)`. - Confirmed current code assigns `offsetTable.keySet()` directly before calling `it.remove()`. - `git diff --check` passed. - Maven is unavailable in this environment, so the required test suite was not run; CI should validate. ## Risk Low; changes only the collection being iterated and preserves existing filtering behavior. AI-assisted contribution; implementation and verification performed against current `develop`. -- 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]
