add logics in the pipelines

[lhubert]

Expected behavior and actual behavior.

As of today our pipelines have only chained processors (one processor passes records to the next, eventually filtering records). This is a bit of a restriction and we might want some additional logic and conditional branching. Knowing that if we allow pipelines to write in different topics, we could serve different types of events.

We are not limited since we can always use the FilterRecords processor and several pipelines.

Steps to reproduce the problem.

Specifications like the version of the project, operating system, or hardware.