wysobj commented on issue #976:
URL: 
https://github.com/apache/rocketmq-client-go/issues/976#issuecomment-1363959191

   > In consumeMessageCurrently, when the consumer fails to consume messages, 
these messages are sent back to RETRY Topic. But in the case of sending back 
those messages failed, the offset of the queue is STILL updated by those 
messages. Eventually these messages are not in the retry topic, and the offset 
skip them behind, which means these messages will never been consumed again. 
![image](https://user-images.githubusercontent.com/11953589/209336571-511f4259-c416-4c03-9dba-208b36b0a2be.png)
   
   found same closed issue:https://github.com/apache/rocketmq-client-go/pull/860


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