ZZhongge commented on issue #3548: URL: https://github.com/apache/rocketmq/issues/3548#issuecomment-982592128
Suppose that you have a message queue list like [(brokerA, 0), (brokerA, 1), (brokerB, 0), (brokerB, 1)], atLeastPickOne return brokerA, and (brokerB, 1) return from tpInfo.selectOneMessageQueue. In this situation, (brokerB, 1) might be changed to (brokerA, 4 % 2), which result in the total list [(brokerA, 0), (brokerA, 1), (brokerB, 0), (brokerA, 0)]. It is an extreme case when all brokers are unavaliable and will be corrected by next term of fetching topic info. But it may be confusing.Thanks for your anwser. -- 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]
