elasticsearch - 从弹性读取msg后Logstash停止

Question

我正在使用logstash和Elastic。
输入为 flex 值，输出为Kafka。
启动logstash时，它将从elastic读取所有消息，然后按预期将其发送到Kafka。
但是一旦处理完所有消息，它就会停止。
不听 future 的消息。是否有任何配置可以保持logstash正常运行？

提前致谢

Answer 1

您可以在配置文件中指定时间表，即

schedule => "* * * * * *"

如果我们希望某项作业每天运行四次，则语法如下:

schedule => "0 */6 * * * /logstash-config.conf"

这意味着每隔6个小时从0开始，即在工作的第0、6、12和18小时开始。