You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "francisoliverlee (via GitHub)" <gi...@apache.org> on 2023/02/08 07:01:16 UTC

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

francisoliverlee opened a new issue, #993:
URL: https://github.com/apache/rocketmq-client-go/issues/993

   client version : v2
   error log:
   ERRO[0000] fetch offset of mq from broker error          MessageQueue="MessageQueue [topic=xxxxxx, brokerName=broker_xxxxx-1, queueId=0]" consumerGroup="xxxxxxx underlayError="broker response code: 22, remarks: Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first"


-- 
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: commits-unsubscribe@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[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"

Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.

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: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

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

Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.

francisoliverlee closed issue #993: push consumer can‘t  consume all queues, and get error "Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first"
URL: https://github.com/apache/rocketmq-client-go/issues/993


-- 
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: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org