# \[Kubernetes Integration\] Custom ingest pipeline for subset of k8s cluster's container's logs

**URL:** <https://discuss.elastic.co/t/kubernetes-integration-custom-ingest-pipeline-for-subset-of-k8s-clusters-containers-logs/314601>\
**Category:** Elastic Agent\
**Tags:** filebeat\
**Created:** [September 16, 2022, 8:55pm UTC](https://discuss.elastic.co/t/kubernetes-integration-custom-ingest-pipeline-for-subset-of-k8s-clusters-containers-logs/314601 "2022-09-16T20:55:11Z")\
**Posts on this page:** 1\
**Showing post:** 2

<div class="post-metadata">

**Author:** ![stephenb](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/stephenb/32/40856_2.png) [@stephenb](https://discuss.elastic.co/u/stephenb)\
**Post date:** [September 16, 2022, 10:19pm UTC](https://discuss.elastic.co/t/kubernetes-integration-custom-ingest-pipeline-for-subset-of-k8s-clusters-containers-logs/314601/2 "2022-09-16T22:19:32Z")

</div>

Which integration?

Is it your custom pipeline or one of the OOTB integrations?

If it a pipeline you wrote you can create a top level pipeline which call the other pipelines based on condition, see [here](https://discuss.elastic.co/t/making-docker-container-logs-go-through-the-right-beats-module-for-processing/312126/9) for an example

---

_[View the full topic](https://discuss.elastic.co/t/kubernetes-integration-custom-ingest-pipeline-for-subset-of-k8s-clusters-containers-logs/314601)._