wysobj opened a new issue, #976: URL: https://github.com/apache/rocketmq-client-go/issues/976
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.  -- 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]
