public void createTopics(final String... topics) throws InterruptedException {
        for (final String topic : topics) {
            createTopic(topic, 1, 1, Collections.emptyMap());
        }
    }
Create multiple Kafka topics each with 1 partition and a replication factor of 1.

@param topics The name of the topics.
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java