guyinyou opened a new pull request, #1324: URL: https://github.com/apache/rocketmq-clients/pull/1324
## Summary - Fix a bug in `TakeMessageQueues` where the index calculation used `next+1` (constant) instead of `next+i` (loop-varying), causing every loop iteration to examine the same message queue - This defeats the round-robin intent and prevents proper load distribution across brokers - The same bug exists in both the main loop and the fallback loop ## Test plan - [ ] Verify round-robin selection distributes across different queues - [ ] Verify existing tests pass -- 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]
