能针对primitive.MessageExt级别做异步ack吗？

[zhangbiaoyg]

针对primitive.MessageExt ，是否可做消息级别的ack啊。现在这种是不是只能在这个处理函数中进行同步处理业务逻辑，因为必须返回成功和失败。如果消息量较大，想将消息分给很多协程处理，处理完成后，针对primitive.MessageExt级别做ack是否可以？

[heshiyingx]

解决方案： 1.设置批量获取的大小为1，处理完一个再进行 下一个。 2.本地数据库进行维护记录，或者将失败的消息再投递一次，再或者只要有一个失败，就返回ConsumeRetryLater，同时告警(前提做好消息幂等处理)

[cserwen]

针对primitive.MessageExt ，是否可做消息级别的ack啊。现在这种是不是只能在这个处理函数中进行同步处理业务逻辑，因为必须返回成功和失败。如果消息量较大，想将消息分给很多协程处理，处理完成后，针对primitive.MessageExt级别做ack是否可以？

SDK 默认就是并发消费，即多个协程去消费一个queue中的消息，使用者不用关心这个并发的问题 @zhangbiaoyg ，只需要针对单条消息做ack即可

[francisoliverlee]

we would close the issue, feel free to re-open it