qianlongzt opened a new issue #618: URL: https://github.com/apache/rocketmq-client-go/issues/618
在集群消费模式下，使用顺序消费。如果消费失败，而后续消费成功，会导致消费失败的消息丢失。 原因在于 https://github.com/apache/rocketmq-client-go/pull/616， put message 只考虑 cachedMsgCount 正确， 没有考虑到的时候，消息应该返回到 msgCache中。 https://github.com/apache/rocketmq-client-go/blob/c6a314851f8c90cbf753d43d683b22ab0e8bf009/consumer/process_queue.go#L95-L108 相关bug https://github.com/apache/rocketmq-client-go/issues/615 ---------------------------------------------------------------- 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]
