Send to different Logstash pipelines based on input

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