我希望我的消费者消费一条消息，然后等待处理完成。我每次消费一条信息。每条消息的处理时间都有点长。因此，同时，如果第二条消息开始处理，则有可能第二条消息首先完成处理，因为我的代码是异步的。这就是为什么我想我的消费第二条消息，只有当它的处理完成。手动管理偏移量不会解决我的问题，因为可能存在重复处理。有没有办法实现顺序处理。