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 to add a Rebalane method before pc.client.UpdateTopicRouteInfo() ```golang //func (pc *pushConsumer) Start() error { //.... pc.Rebalance() time.Sleep(1 * time.Second) 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) } } //} ``` It seems to work ``` INFO[0000] queryTopicRouteInfoFromServer, topic: %RETRY%go-auto-create-group110, response: Code: 17, opaque: 2, Remark: No topic route info in name server for the topic: %RETRY%go-auto-create-group110 See http://rocketmq.apache.org/docs/faq/ for further details., ExtFields: map[] WARN[0000] query topic route from server error: topic not exist ERRO[0000] >>>>>>>>>>>>>>>>>>>>>> consumer group is not auto creating, err: map[%RETRY%go-auto-create-group110:true order:true] INFO[0000] queryTopicRouteInfoFromServer topic:%RETRY%go-auto-create-group110 INFO[0000] queryTopicRouteInfoFromServer, topic: %RETRY%go-auto-create-group110, response: Code: 17, opaque: 3, Remark: No topic route info in name server for the topic: %RETRY%go-auto-create-group110 See http://rocketmq.apache.org/docs/faq/ for further details., ExtFields: map[] WARN[0000] query topic route from server error: topic not exist WARN[0000] do balance of group: go-auto-create-group110, but topic: %RETRY%go-auto-create-group110 does not exist. WARN[0000] do balance of group: go-auto-create-group110, but topic: %RETRY%go-auto-create-group110 does not exist. INFO[0000] receive broker's notification, the consumer group: go-auto-create-group110 ``` I guess that it calls RebalanceImmediately for creating a %RETRY% topic.
---------------------------------------------------------------- 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
