Support for Dynamic Kafka Topics