Send to different Logstash pipelines based on input

Hi

i have two logstash pipelines in Pipelines.yml. I need to redirect events to appropriate pipelines based on input. If input is "abc", send to pipeline "pipeline 1", else send to "pipeline2". I cant handle this at sources. All sources will send to same logstash port 1468. How to achive this? I read about filebeat. But it seems not possible in filebeat.

Regards
Ram

Check out the distributor pattern. I think that will work for you.