我正在使用基于拉的消息队列。当前的消费方法是使用 Spring 的@Scheduled注解定期从队列中拉取，处理消息并返回队列。您可以假设消费者 API 具有以下方法
interface MessageConsumer {
List<Message> consume(int fetchSize);
void commit();
}
如何使用反应器重写它？基本上，我想将消息转化为Flux<Message>具有背压意识的内容。有没有办法简单地使用现有的 API 来完成结果？还是我需要像reactor-kafka以前那样实现自己的消费者事件循环？