You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "fujian-zfj (via GitHub)" <gi...@apache.org> on 2024/03/14 04:36:49 UTC
[I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
fujian-zfj opened a new issue, #7914:
URL: https://github.com/apache/rocketmq/issues/7914
### 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
linux
### RocketMQ version
5.2
### JDK Version
jdk 1.8
### Describe the Bug
### Steps to Reproduce
1.keep send messages to broker
2.start pop consumer, then every pop request may pull 0 ~ 32 messages,
3.ack messages randomly
### What Did You Expect to See?
Those messages unacked should be sent to retryTopic, then be consumed by consumer util being acked.
### What Did You See Instead?
Some unacked messages were lost.
### 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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
Posted by "fujian-zfj (via GitHub)" <gi...@apache.org>.
fujian-zfj commented on issue #7914:
URL: https://github.com/apache/rocketmq/issues/7914#issuecomment-1996746520
> The storeTime is the store time of each original message, not the latest store time related to the popCheckPoint. It doesn't look like 'storeTime > popTime' would happen？
--
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
Re: [I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
Posted by "fujian-zfj (via GitHub)" <gi...@apache.org>.
fujian-zfj commented on issue #7914:
URL: https://github.com/apache/rocketmq/issues/7914#issuecomment-2002870249
> > > The storeTime is the store time of each original message, not the latest store time related to the popCheckPoint. It doesn't look like 'storeTime > popTime' would happen？
> >
> >
> > 
>
> Indeed. I ignored the timing of popTime assignment, which is before calling of the MessageStore.getMessageAsync().
Yes, this is the root cause of the bug.
--
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
Re: [I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
Posted by "RongtongJin (via GitHub)" <gi...@apache.org>.
RongtongJin closed issue #7914: [Bug] pop revive msg to retry topic may lose messages
URL: https://github.com/apache/rocketmq/issues/7914
--
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
Re: [I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
Posted by "redlsz (via GitHub)" <gi...@apache.org>.
redlsz commented on issue #7914:
URL: https://github.com/apache/rocketmq/issues/7914#issuecomment-1997180866
> > The storeTime is the store time of each original message, not the latest store time related to the popCheckPoint. It doesn't look like 'storeTime > popTime' would happen？
>
> 
Indeed. I ignored the timing of popTime assignment, which is before calling of the MessageStore.getMessageAsync().
--
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
Re: [I] [Bug] pop revive msg to retry topic may lose messages [rocketmq]
Posted by "redlsz (via GitHub)" <gi...@apache.org>.
redlsz commented on issue #7914:
URL: https://github.com/apache/rocketmq/issues/7914#issuecomment-1996617108
The storeTime is the store time of each original message, not the latest store time related to the popCheckPoint. It doesn't look like 'storeTime > popTime' would happen？
--
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