apache-kafka - Spring Batch + Kafka：KafkaItemReader 永远运行？

Question

我想做一些东西来持续监控一些 Kafka 主题，然后在收到消息时执行一些批处理作业（点击一些 REST api 并存储响应）。我用 KafkaItemReader 设置了一些东西，但是，如果它根据 pollTimeout 在 30 秒内没有收到消息，它就会关闭。我怎样才能让它无限期地运行？由于这不是一个明显的选择，我想知道我是否使用了正确的工具来完成这项工作。

标签： apache-kafkaspring-batch

Answer 1

可能的答案：你不应该这样做。

这是正确的。批处理是关于处理有限的数据集。如果您的数据源是无限的记录流，并且您希望持续监控它，那么流式解决方案更适合您的用例。