Error: The message queue is not in assigned list, may be rebalancing

[cj495840252]

求助大佬，我用DefaultLitePullConsumer创建consumer的后调用seekToBegin和seekToEnd方法都会报这个错,
java lib rocketmq-client: 5.0.0
rocketmq: 5.0.0

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)