public void createTopic(final String topic) {
        createTopic(topic, 1, 1, Collections.emptyMap());
    }
Create a Kafka topic with 1 partition and a replication factor of 1.

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