yaphetsglhf commented on issue #650: URL: https://github.com/apache/rocketmq-client-go/issues/650#issuecomment-826103908
well, I found that If I consumer message failed and return `SuspendCurrentQueueAMoment`, then next time, when I pull messages again, I will only get the latest messages. but if i restart the container, I will receive messages from the earliest offset, then I will get the former failed messges. -- 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: [email protected]
