heshiyingx commented on issue #1067: URL: https://github.com/apache/rocketmq-client-go/issues/1067#issuecomment-1577830954
解决方案： 1.设置批量获取的大小为1，处理完一个再进行 下一个。 2.本地数据库进行维护记录，或者将失败的消息再投递一次，再或者只要有一个失败，就返回ConsumeRetryLater，同时告警(前提做好消息幂等处理) -- 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]
