Re: [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]

DongyuanPan commented on issue #228:
URL: https://github.com/apache/rocketmq-mqtt/issues/228#issuecomment-1846874228

   > 
![image](https://private-user-images.githubusercontent.com/24490175/287230545-706ab426-168f-4fba-976c-5ab748291554.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTEiLCJleHAiOjE3MDIwMjgzNTgsIm5iZiI6MTcwMjAyODA1OCwicGF0aCI6Ii8yNDQ5MDE3NS8yODcyMzA1NDUtNzA2YWI0MjYtMTY4Zi00ZmJhLTk3NmMtNWFiNzQ4MjkxNTU0LnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFJV05KWUFYNENTVkVINTNBJTJGMjAyMzEyMDglMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjMxMjA4VDA5MzQxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTcwNmUyZTFmNGM4MGM3MjViNjc3NjZmY2I0MDZlMWM1ZjU0ZDRlYjc1NTk1ZDJiYTRmMTQ3NzdmMjQ1OTNhYWUmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.2mkxAHauKkIJt8beob0lArIgsqmS0GP8aHPauQn0ExA)
 请问目前我的解决办法是否够优雅？
   
   不建议这么修改，可以修改下面的代码取到正确的topic：
   
quene.toFirstTopic时，判断一下是p2p和retry吗？如果是的话，就返回对应参数设置的p2p和retry的topic(这两个topic在配置里面要求提前在broker创建了)。
   
   不过如果broker集群没有扩缩容，这个报错应该只会第一次出现一次吧，后续有别的topic（一级topic）会更新相应的broker地址。
   


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

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org