ltm54250 opened a new issue #657: URL: https://github.com/apache/rocketmq-client-go/issues/657
I'm using rocketmq and rocketmq broker is deployed with deployment in k8s. I can connect rocketmq name server with a static ip(cluster ip) but broker ip(pod ip) is dynamic. Now I'm using rocketmq.PushConsumer to consume message. I can't connect new broker when broker pod restarted and new broker pod get a new ip. I think my consumer can't refresh broker ip list when old broker pod down and new broker pod up. Please tell me how to connect new broker. If I can't do it, please tell me how to catch error when it occur. My code refer this link. https://github.com/apache/rocketmq-client-go/blob/master/examples/consumer/simple/main.go log like : ERRO[0066] get consumer list of group from broker error -- 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]
