I'm using the mongo source connector in order to produce messages from mongo to Kafka. In my use case, I need to dynamically decide on the target topic, based on some of the mongo document values. Is there any way to do so? I tried to use this SMT but it didn't work (the message wasn't produced to any topic).
Any ideas? Thanks!