[GitHub] [rocketmq-client-go] francisoliverlee commented on issue #993: push consumer can‘t consume all queues, and get error "Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first"

Tue, 07 Feb 2023 23:23:10 -0800 


francisoliverlee commented on issue #993:
URL: 
https://github.com/apache/rocketmq-client-go/issues/993#issuecomment-1422137479

   可能的分析：对比golang client和java client发现不一致， 大家觉得呢？
   
   - golang 
   通过代码得知，如果broker返回 “Not found, V3_0_6_SNAPSHOT maybe this group consumer boot 
first”，返回offset=-2
   
![image](https://user-images.githubusercontent.com/5908412/217460790-94e94a1e-3715-4ad0-8758-8ee961e82cb8.png)
   
   
   - java
   java的代码调用链为: readOffset() -> fetchConsumeOffsetFromBroker() -> 
queryConsumerOffset().
   如果broker返回 “Not found, V3_0_6_SNAPSHOT maybe this group consumer boot 
first”， 在queryConsumerOffset()中则抛异常，异常直到被readOffset()捕获，返回offset=-1
   
   
![image](https://user-images.githubusercontent.com/5908412/217461141-f7870cb0-9012-4912-945d-04d5c24482b2.png)
   
![image](https://user-images.githubusercontent.com/5908412/217460976-efedcd5a-bb28-4ed1-b5c3-992286c1e69c.png)
   


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to