MQTT source - possibility to add prefix to kafka topic

[dberardo-com]

i want to have 2 source connectors reading from the same mqtt topic and writing to 2 different kafka topics. why i need this? because i am using a different partitioning key

is it possible to a add a prefix so "select * from" to add to the kafka topic name ?

[stheppi]

HI @dberardo-com

Not at the moment. you could use an SMT to adapt the topic name.

[dberardo-com]

Thanks for the reply.

So are you suggesting to create 2 connectors, 1 of which would use an SMT to rewrite the topic name?

As I am using wildcard mqtt subscriptions, di you know any SMT that can rewrite topic names dynamically (e.g. using regex or so)? Or maybe simply appending a suffix "_copy" to the topic names?