Used to mirror some subset of the events (traps & syslogs) from a Kafka cluster to another - View it on GitHub