class KafkaAdminClient implements Closeable {

    public void createTopic(String topic, int partitions, int replicationFactor) {
        createTopic(topic, partitions, replicationFactor, new Properties());
    }

    public  KafkaAdminClient(Properties properties);

}