kingkh1995 opened a new issue, #655: URL: https://github.com/apache/rocketmq-clients/issues/655
### Before Creating the Bug Report - [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions) of this repository and believe that this is not a duplicate. - [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Programming Language of the Client Go ### Runtime Platform Environment Windows 11 ### RocketMQ Version of the Client/Server 2d3cdf735e27a3c3a9e1786d0ee7c8318ba1578c ### Run or Compiler Version _No response_ ### Describe the Bug 使用SimpleConsumer进行消费，由于subTopicRouteDataResultCache中TopicRoute的失效，会重新创建SubscriptionLoadBalancer，由于没有给index一个随机值（Java client中给定了一个随机值），导致index总是从0开始，在awaitDuration值设置过大的场景下，可能永远都无法从排序靠后的队列中拉取消息，导致永远存在消息堆积。 If use SimpleConsumer for consumption, due to the invalidation of the TopicRoute in the subTopicRouteDataResultCache, the SubscriptionLoadBalancer will be recreated, because the index is not given a random value (a random value is given in the Java client), the index always starts from 0, If the awaitDuration value is set too large, You may never be able to pull a message from a queue that is lower in order. ### Steps to Reproduce 1. create a cluster with 2 broker in proxy local mode; 2. create a topic with 8 read-write queue; 3. send a certain number of messages then stop; 4. use SimpleConsumer ; ### What Did You Expect to See? 使用SimpleConsumer，发送一批消息后，所有消息都能被消费到。 Use SimpleConsumer, after sending a batch of messages, all messages can be consumed. ### What Did You See Instead? 使用SimpleConsumer，发送一批消息后，永远都有部分消息无法被拉取。 Use SimpleConsumer, after sending a batch of messages, there will always be some messages that cannot be pulled. ### Additional Context _No response_ -- 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: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
