wolftankk edited a comment on issue #194: [native]PushConsumer clustering does not auto create group URL: https://github.com/apache/rocketmq-client-go/issues/194#issuecomment-543487967 It does not seem to work. ``` pc.client.UpdateTopicRouteInfo() for k := range pc.subscribedTopic { _, exist := pc.topicSubscribeInfoTable.Load(k) if !exist { pc.client.Shutdown() return fmt.Errorf("the topic=%s route info not found, it may not exist", k) } } ``` I'm still looking for it. --- DEBUG INFO: **1 . FIRST** ``` INFO[0000] queryTopicRouteInfoFromServer topic:%RETRY%go-auto-create-group108 INFO[0000] queryTopicRouteInfoFromServer, topic: %RETRY%go-auto-create-group108, response: Code: 17, opaque: 2, Remark: No topic route info in name server for the topic: %RETRY%go-auto-create-group108 See http://rocketmq.apache.org/docs/faq/ for further details., ExtFields: map[] WARN[0000] query topic route from server error: topic not exist ``` It calls remote cmd: queryTopicInfo, get code: **17** **2. SECOND (waiting 10 sec)** ``` INFO[0000] queryTopicRouteInfoFromServer topic:%RETRY%go-auto-create-group108 INFO[0000] queryTopicRouteInfoFromServer, topic: %RETRY%go-auto-create-group108, response: Code: 0, opaque: 5, Remark: , ExtFields: map[] INFO[0000] receive broker's notification, the consumer group: go-auto-create-group108 ``` It calls remote cmd: queryTopicInfo, get code: **0** --- And, I try delete ```golang if !exist { pc.client.Shutdown() return fmt.Errorf("the topic=%s route info not found, it may not exist", k) } ``` It seems to work
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
