pzhx521 opened a new issue, #1048: URL: https://github.com/apache/rocketmq-client-go/issues/1048
https://github.com/apache/rocketmq-client-go/blob/1d86ea68616504c6985586d2a9bd1d47c312246f/examples/consumer/pull/pull_from/main.go#L95 I'm going to implement an example of `pull_from`, I found related example in `examples` file. But I have a doubt, why use the `FetchPublishMessageQueues` method? `FetchSubscriptionMessageQueues` should not be used to fetch consumer queues. Publish and Subscribe Queues should be two different queues. But `Admin` does not provide the `FetchSubscriptionMessageQueues` interface, I think it is necessary to provide an interface to get the consumer queue. https://github.com/apache/rocketmq-client-go/blob/1d86ea68616504c6985586d2a9bd1d47c312246f/admin/admin.go#LL33C6-L33C6  Do we need to add `FetchSubscribeMessageQueues` method in `Admin`, or do we take other methods. ``` func (a *admin) FetchSubscribeMessageQueues(ctx context.Context, topic string) ([]*primitive.MessageQueue, error) { return a.cli.GetNameSrv().FetchSubscribeMessageQueues(utils.WrapNamespace(a.opts.Namespace, topic)) } ``` Looking forward to your reply, thank you. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
