public void createTopic(final String topic, final int partitions, final int replication) throws InterruptedException {
        createTopic(topic, partitions, replication, Collections.emptyMap());
    }
Create a Kafka topic with the given parameters.

@param topic       The name of the topic.
@param partitions  The number of partitions for this topic.
@param replication The replication factor for (the partitions of) this topic.
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java