[GitHub] [rocketmq] panzhi33 opened a new issue #1600: Message consumption takes more than 15 minutes, it is possible to generate two identical messages in the retry topic

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

panzhi33 opened a new issue #1600: Message consumption takes more than 15 minutes, it is possible to generate two identical messages in the retry topic
URL: https://github.com/apache/rocketmq/issues/1600
 
 
   Message consumption takes more than 15 minutes, it is possible to generate two identical messages in the retry topic。
   
   When the message is consumed for more than 15 minutes, then
   org.apache.rocketmq.client.impl.consumer.ProcessQueue#cleanExpiredMsg this method scans and finds，will send this message to the retry topic and delete it from the cache.
   
   but this message is still consumer . finally, in org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently#consumeMessage this method, this message will be consumed more than once if the return is successful or failed.
   

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


With regards,
Apache Git Services