我想通过使用管道到管道体系结构模式之一（分支路径模式）来重构Logstash管道。上游管道的输入是使用elasticsearch输入插件对Elasticsearch集群的一次性查询。因此，向下游输入的数量是有限的。
但是，当下游管道消耗并处理了所有输入后，Logstash不会关闭-就像我不使用管道到管道通信时那样。
这是预期的行为吗？当所有下游管道处理完所有上游事件后，是否有办法关闭Logstash？
谢谢
（我最初在discuss.elastic.co上问过这个问题，但没有得到答复）
i_michael 回答：使用管道到管道通信时关闭Logstash
暂时没有好的解决方案，如果你有好的解决方案，请发邮件至：iooj@foxmail.com