navychi opened a new issue #497: URL: https://github.com/apache/rocketmq-client-go/issues/497
rmqClient will put into clientMap(sync.Map) when create a new GetOrNewRocketMQClient.  But rmqClient did not remove when shutdown consumer.  So if I want to shutdown the consumer. And then re-start consumer again(Required by business logic), The new consumer will use old connection which is closed. So if I want to realization consumer restart logic. Will it be supported in the future. or The Architecture design is like this which not ready to support consumer restart logic. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
