Spring-kafka消费暂停不会立即执行

Question

在使用kafka时，遇到了业务需求。需要在消费一条消息后，暂停消费。等回调接口触发时，恢复消费。
我使用的是Spring-kafka注解@KafkaListener。
在网上搜索一大堆后，得到了一种方式：

这种方式暂停或停止监听消费
是等消费完所有消息才会执行。并不会立刻暂停或停止。
我想要的是立即暂停消费行为。如何实现？

Answer 1

你可以在消费的逻辑里同步等待回调接口，然后再提交offset。