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-unsubscr...@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
