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

@param topic The name of the topic.
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java