Hi, this is a duplicated of a question I posted last year, and yet unanswered/unsolved (original question).
I would like to use one of the pipeline-to-pipeline architecture patterns, say, the forked path pattern. The input of the upstream pipeline is a one-time query to an Elasticsearch cluster, using the elasticsearch input plugin. Although the number of inputs to downstream is finite, Logstash does not terminate when the downstream pipelines have consumed and processed all the inputs (as it would terminate, if I don't use pipeline-to-pipeline solutions).
Is there a way to force Logstash termination when all the downstream pipelines have processed all the events coming from upstream?