如何每 5 分钟消费一次来自 kafka 主题的 kafka 消息，而不是使用云流连续消费它

Question

我希望每 5 分钟使用一次来自 kafka 主题的消息，然后对其进行处理并使用 Spring Cloud Stream 将其发送到另一个主题。有什么想法吗？

Answer 1

使用PollableMessageSource - 请参阅the documentation。

您必须将max.poll.interval.ms 设置为大于其默认值（300000 - 5 分钟）以避免重新平衡。