rocketmq-client-go icon indicating copy to clipboard operation
rocketmq-client-go copied to clipboard

how to query brokerName according to topic

Open lweiiii opened this issue 1 year ago • 1 comments

在发送的消息的时候,准备使用NewManualQueueSelector,但是NewManualQueueSelector依赖message的自己的Queue消息。 在构造Queue消息的时候,需要Topic、BrokerName和QueueId。 这个BrokerName的获取方法貌似在internal包下,其他的地方貌似没有可以获取BrokerName的方法

lweiiii avatar Apr 15 '23 16:04 lweiiii

you can try admin#FetchPublishMessageQueues()

francisoliverlee avatar Apr 24 '23 14:04 francisoliverlee