rocketmq-client-go
rocketmq-client-go copied to clipboard
how to query brokerName according to topic
在发送的消息的时候,准备使用NewManualQueueSelector,但是NewManualQueueSelector依赖message的自己的Queue消息。 在构造Queue消息的时候,需要Topic、BrokerName和QueueId。 这个BrokerName的获取方法貌似在internal包下,其他的地方貌似没有可以获取BrokerName的方法
you can try admin#FetchPublishMessageQueues()