[I] 项目升级rocketmq-client 5.1.4版本后，org.apache.rocketmq.mqtt.ds.store.LmqQueueStoreManager#maxOffset 方法，报throw new MQClientException("The broker[" + queue.getBrokerName() + "] not exist", null); [rocketmq-mqtt]

[via GitHub]

lzkisok opened a new issue, #228:
URL: https://github.com/apache/rocketmq-mqtt/issues/228

   原因如下：
   
![image](https://github.com/apache/rocketmq-mqtt/assets/24490175/42f8170f-4720-4e6b-926c-8f62b02e95cd)
   如上图，获取不到brokerAddr
   更近一步的原因是：
   
![image](https://github.com/apache/rocketmq-mqtt/assets/24490175/3f02e10f-941c-4f3d-b484-de3773e4e713)
   
   
![image](https://github.com/apache/rocketmq-mqtt/assets/24490175/d16929b4-c37b-40ef-bd78-01d6a8e844dc)
   
如上图，DefaultMQPullConsumer，没有topic，不会调用this.updateTopicRouteInfoFromNameServer(topic);导致this.brokerAddrTable为空，获取失败
   
   this.updateTopicRouteInfoFromNameServer() 方法在rocketmq-client 4.9.3版本中的写法如下图：
   
![image](https://github.com/apache/rocketmq-mqtt/assets/24490175/9af18777-197b-4e10-9679-878af4e6e322)
   可以正常调用。


-- 
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