[GitHub] [rocketmq-client-go] jackedelic opened a new issue, #937: Offset - ConsumeFromWhere does not take effect

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

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

   **BUG REPORT**  
   1. Please describe the issue you observed:
   We initialize a consumer by specifying ConsumeFromWhere to specify where in the partition to consumer the message from.
   
   We specify `consumer.ConsumeFromLastOffset` option when initializing a new `PushConsumer`. We expect the consumer **to not consume** messages produced before this point in time.
   
   However, old messages are still being consumed instead of starting from the last offset.
   
   3. Please tell us about your environment:
   
        - What is your OS? x86_64 GNU/Linux
   
        - What is your client version? github.com/apache/rocketmq-client-go/v2 v2.1.1
   
        - What is your RocketMQ version?
   
   I appreciate if any person with the relevant knowledge could advise us on the status so my team has a concrete plan on our end. To be more specific, we use this rocketmq client sdk to develop rocketmq consumer feature for our customers, and we would like to explicitly inform our customers whether we support ConsumeFromLastOffset option or not. Thanks again for any inputs.
   
   


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

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

[GitHub] [rocketmq-client-go] jackedelic commented on issue #937: Offset - ConsumeFromWhere does not take effect

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

jackedelic commented on issue #937:
URL: https://github.com/apache/rocketmq-client-go/issues/937#issuecomment-1276143869

   I see. Noted with thanks. I appreciate your inputs.


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

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

[GitHub] [rocketmq-client-go] ShannonDing commented on issue #937: Offset - ConsumeFromWhere does not take effect

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

ShannonDing commented on issue #937:
URL: https://github.com/apache/rocketmq-client-go/issues/937#issuecomment-1275484122

   This parameter takes effect only for the first-time CounsumerGroup. If the current ConsumerGroup has been used and then restarted, the configuration of this parameter will not take effect, by default, consumers will continue to consume from the last saved offset. 
   for some case, if you need to discard historical data and start consumption from the latest offset, you can reset the offset by admin tools to move the consumption offset to the latest time.
   
   Admin tools: https://rocketmq.apache.org/zh/docs/4.x/%e9%83%a8%e7%bd%b2%e4%b8%8e%e8%bf%90%e7%bb%b4/16admintool/


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

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

[GitHub] [rocketmq-client-go] jackedelic closed issue #937: Offset - ConsumeFromWhere does not take effect

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

jackedelic closed issue #937: Offset - ConsumeFromWhere does not take effect
URL: https://github.com/apache/rocketmq-client-go/issues/937


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

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