项目升级rocketmq-client 5.1.4版本后,org.apache.rocketmq.mqtt.ds.store.LmqQueueStoreManager#maxOffset 方法,报throw new MQClientException("The broker[" + queue.getBrokerName() + "] not exist", null);
- Dominant language
- Java
- Stars
- 209
- Forks
- 72
- PR merge metrics
- No merged PRs in 30d
Description
原因如下:

如上图,获取不到brokerAddr,导致报The broker[" + queue.getBrokerName() + "] not exist
更近一步的原因是:


如上图,DefaultMQPullConsumer,没有topic,不会调用this.updateTopicRouteInfoFromNameServer(topic);导致this.brokerAddrTable为空,获取失败
this.updateTopicRouteInfoFromNameServer() 方法在rocketmq-client 4.9.3版本中的写法如下图:

可以正常调用。
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.