# How to implement forked path pattern pipeline

**URL:** <https://discuss.elastic.co/t/how-to-implement-forked-path-pattern-pipeline/251154>\
**Category:** Elasticsearch\
**Created:** [October 6, 2020, 3:04pm UTC](https://discuss.elastic.co/t/how-to-implement-forked-path-pattern-pipeline/251154 "2020-10-06T15:04:21Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![mohsin106](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/mohsin106/32/65203_2.png) [@mohsin106](https://discuss.elastic.co/u/mohsin106)\
**Post date:** [October 6, 2020, 3:04pm UTC](https://discuss.elastic.co/t/how-to-implement-forked-path-pattern-pipeline/251154/1 "2020-10-06T15:04:21Z")

</div>

Hi, I need some guidance understanding how to implement a forked path pattern pipeline as described [here](https://www.elastic.co/guide/en/logstash/7.9/pipeline-to-pipeline.html#forked-path-pattern).

I'm running Logstash in a Kubernetes environment and have the following configured in my **logstash.yml** file:

> xpack.management.elasticsearch.hosts: ['https://escluster\_ip:443']  
> xpack.management.elasticsearch.password: "password"  
> xpack.management.elasticsearch.username: "username"  
> xpack.management.enabled: true  
> xpack.management.pipeline.id: [pipelineA, pipelineB, pipelineC]  
> xpack.monitoring.elasticsearch.hosts: ['https://escluster\_ip:443']  
> xpack.monitoring.elasticsearch.password: "password"  
> xpack.monitoring.elasticsearch.username: "username"  
> xpack.monitoring.enabled: true

When the Logstash container starts up it triggers pipelineA, pipelineB, and pipelineC to start up.

I want to have the data coming out of pipelineA reparsed with a new pipeline ( **pipelineD** ). How do I do that? How would I reference pipelineA's output inside of pipelineD? How do I configure pipelineA's output to send the data to pipelineD? Also, will I need to add pipelineD to the logstash.yml file above? Once pipelineD is finished parsing the data it should send it to my ES cluster.

Do I need to put the "queue.type: persisted" and "config.string: ..." configs in my logstash.yml file?

Thank you.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [November 3, 2020, 3:04pm UTC](https://discuss.elastic.co/t/how-to-implement-forked-path-pattern-pipeline/251154/2 "2020-11-03T15:04:22Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.