wolftankk edited a comment on issue #194: PushConsumer clustering does not auto create group URL: https://github.com/apache/rocketmq-client-go/issues/194#issuecomment-529283996 hmm, Maybe this code triggers the problem. github.com/apache/rocketmq-client-go/consumer/push_consumer.go:151 ```go 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 retry more times, find a solution. 1. [FIRST TIME] use a new group (with clustering). use c.Start(). catch a error. ``` the topic=%RETRY%go-auto-create-group7 route info not found, it may not exist ``` **and MUST wait 10 seconds.** 2. [SECOND TIME] run c.Start(). catch a error ``` INFO[0000] the topic [%RETRY%go-auto-create-group8] route info changed, old <nil> ,new {"OrderTopicConf":"","queueDatas":[{"brokerName":"iz8vbahalty0z0999g241tz","readQueueNums":1,"writeQueueNums":1,"perm":6,"topicSynFlag":0}],"brokerDatas":[{"cluster":"DefaultCluster","brokerName":"iz8vbahalty0z0999g241tz","brokerAddrs":{"0":"10.100.1.178:10911"}}]} INFO[0000] receive broker's notification, the consumer group: go-auto-create-group8 ERRO[0000] fetch offset of MessageQueue [topic=RECHARGE_MOBILE, brokerName=iz8vbahalty0z0999g241tz, queueId=0] error: broker response code: 22, remarks: Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first ``` 3. [THIRD TIME] run c.Start(). it's working.
---------------------------------------------------------------- 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] With regards, Apache Git Services
