Я хотел бы провести рефакторинг своих конвейеров Logstash, используя один из шаблонов архитектуры от конвейера к конвейеру (шаблон разветвленного пути). Ввод восходящего конвейера - это однократный запрос к кластеру Elasticsearch, использующий плагин вводаasticsearch. Поэтому количество входов в нисходящий поток конечно.
Однако, когда нисходящие конвейеры потребляют и обрабатывают все входы, Logstash не завершает работу - как это происходит, когда я не использую конвейер доконвейеры связи.
Это ожидаемое поведение? Есть ли способ выключить Logstash, когда все последующие конвейеры обработали все события, поступающие из восходящего потока?
Спасибо
(я изначально задавал этот вопрос на обсуждении. astic.co , но я не получил ответа)