Test pipeline output to multiple sinks (e.g. Kafka topics)

[deepyaman]

This results in multiple awaitTermination calls for certain output sinks, which would block each other using SequentialRunner. ParallelRunner could be a fairly easy solution, but needs to be validated.