apache-kafka - 每 X 分钟轮询一次来自 kafka 主题的消息

Question

我想知道在我的 Kafka Streams 应用程序或 Spring-Kafka 中；

有没有一种方法可以让我在某个时间间隔内从某个主题中读取我的消息。

假设每 5 分钟读取 1000 条记录。

从一个主题中读取 1000 条记录，再次等待 5 分钟，再次消费 1000 条消息。

我已经阅读了 .poll() 文档，但它并没有做我真正想要的。它说

 The configuration poll.ms is the maximum "blocking time" within poll() if no data avaliable.

像一个缓慢的通知处理一样思考。我可以使用消费者、生产者 api 或使用 kafka 流来处理这个问题吗？

谢谢 ！

标签： apache-kafkaspring-kafka