I don’t understand this, you don’t have to explicitly create Kafka topics unless you configure this to be a requirement.

I’ve implemented exactly what you talk about using dynamic topics in Kafka and it was trivial.

Maybe I’m missing something?