Create Kafka input topic when launching a topology