Dynamic create kafka topic

KafkaTopicUtil.java

package com.hello.world;

import joptsimple.internal.Strings;
import kafka.admin.AdminUtils;
import kafka.admin.RackAwareMode;
import kafka.utils.ZKStringSerializer$;
import kafka.utils.ZkUtils;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.ZkConnection;

import java.util.List;
import java.util.Properties;

public class KafkaUtils {
		
	public static void createTopic(String topic,int partitions,List<String> zkList) {
		String zkServers = Strings.join(zkList, ",");
		int sessionTimeoutMs = 10 * 1000;
		int connectionTimeoutMs = 8 * 1000;
		ZkClient zkClient = null;
		ZkUtils zkUtils = null;
		try{
			zkClient = new ZkClient(
					zkServers,
					sessionTimeoutMs,
					connectionTimeoutMs,
					ZKStringSerializer$.MODULE$);
			zkUtils = new ZkUtils(zkClient, new ZkConnection(zkServers), false);
			int replication = 2;
			Properties topicConfig = new Properties();
			AdminUtils.createTopic(zkUtils, topic, partitions, replication, topicConfig, RackAwareMode.Enforced$.MODULE$);
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			if(zkClient!=null){
				zkClient.close();
			}
		}
	}
    
}