[GitHub] [rocketmq-client-go] wolftankk edited a comment on issue #194: PushConsumer clustering does not auto create group

[GitBox <gi...@apache.org>]

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
   ```
   
   ctrl - c .
   
   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:
users@infra.apache.org


With regards,
Apache Git Services