Mirror Maker - Filtering messages on topic based on key/value in headers

DevOps Kafka
1

Hi all! Does anyone know if Mirror Maker 2 can filter messages on specific topic based on a key value in message header? e.g.

I have a topic called topic_a which I mirror to another Kafka cluster, and in that topic there are messages which have headers that consist of key value pairs, such as:

produced_by=app_1

Now, I would like to filter based on that key value pair. Is it possible to do so with Mirror Maker 2, or can I do it with some other tool?

2

Using transforms should be possible. I’m not sure there is one that filters based on record headers though