Re: [D] Error: The message queue is not in assigned list, may be rebalancing [rocketmq]

[via GitHub]

GitHub user cj495840252 edited a discussion: Error: The message queue is not in 
assigned list, may be rebalancing

求助大佬，我用DefaultLitePullConsumer创建consumer的后调用seekToBegin和seekToEnd方法都会报这个错,
java lib rocketmq-client: 5.0.0
rocketmq: 5.0.0
```java
public class Main {
    private final static String nameServer = "127.0.0.1:9876";
    private final static String consumerGroup = "test";
    private final static String topic = "test";
    public static void main(String[] args) throws MQClientException, 
IOException {
        // 初始化consumer，并设置consumer group name
        DefaultLitePullConsumer consumer = new 
DefaultLitePullConsumer(consumerGroup);
        // 设置NameServer地址
        consumer.setNamesrvAddr(nameServer);
        // 订阅一个或多个topic，并指定tag过滤条件，这里指定*表示接收所有tag的消息
        consumer.subscribe(topic, "*");
        //设置采用广播模式，广播模式下，消费组内的每一个消费者都会消费全量消息。
        //consumer.setMessageModel(MessageModel.BROADCASTING);
        //注册回调接口来处理从Broker中收到的消息
        // 启动Consumer
        consumer.start();
        Collection<MessageQueue> queues = consumer.fetchMessageQueues("test");
        System.out.println(queues);

        // 设置offset
        consumer.seekToBegin(queues.iterator().next());
        System.in.read();
    }

}
```
这是整个error
```
Exception in thread "main" 
org.apache.rocketmq.client.exception.MQClientException: The message queue is 
not in assigned list, may be rebalancing, message queue: MessageQueue 
[topic=test, brokerName=broker-a, queueId=0]
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
        at 
org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.seek(DefaultLitePullConsumerImpl.java:656)
        at 
org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.seekToBegin(DefaultLitePullConsumerImpl.java:686)
        at 
org.apache.rocketmq.client.consumer.DefaultLitePullConsumer.seekToBegin(DefaultLitePullConsumer.java:376)
        at org.example.Main.main(Main.java:43)
```

GitHub link: https://github.com/apache/rocketmq/discussions/7910

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org