lizhimins opened a new issue, #7035:
URL: https://github.com/apache/rocketmq/issues/7035

   ### Before Creating the Bug Report
   
   - [X] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [X] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [X] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   MacOS, JDK 11
   
   ### RocketMQ version
   
   branch: develop latest
   
   ### JDK Version
   
   JDK11
   
   ### Describe the Bug
   
   When resetting the consumer's offset to an earlier time to start consuming 
data from tiered storage, we use "clean expired" to remove older data because 
commitlog and consume queue file have their own lifecycles. However, it is 
possible for cq file to still exist while the commitlog no longer exists. In 
this scenario, the data pointed to by cq unit is empty and there is no 
reasonable "next begin offset" to provide, preventing the client from 
correcting the position and self-healing the consumption process.
   
   ### Steps to Reproduce
   
   No.
   
   ### What Did You Expect to See?
   
   Fix offset failed.
   
   ### What Did You See Instead?
   
   No.
   
   ### Additional Context
   
   _No response_


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