You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by "cj495840252 (via GitHub)" <gi...@apache.org> on 2024/03/13 12:03:12 UTC
[D] Error: The message queue is not in assigned list, may be rebalancing [rocketmq]
GitHub user cj495840252 created 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 = "test2";
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");
// 设置offset
consumer.seekToBegin(queues.iterator().next());
System.out.println(queues);
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-unsubscribe@rocketmq.apache.org
Re: [D] Error: The message queue is not in assigned list, may be rebalancing [rocketmq]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
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 = "test2";
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-unsubscribe@rocketmq.apache.org
Re: [D] Error: The message queue is not in assigned list, may be rebalancing [rocketmq]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
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 = "test2";
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");
// 设置offset
consumer.seekToBegin(queues.iterator().next());
System.out.println(queues);
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-unsubscribe@rocketmq.apache.org
Re: [D] Error: The message queue is not in assigned list, may be rebalancing [rocketmq]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
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-unsubscribe@rocketmq.apache.org