- ZkUtils zkUtils = ZkUtils.apply("localhost:2181", 30000, 30000, JaasUtils.isZkSecurityEnabled());
- // 创建一个单分区单副本名为t1的topicAdminUtils.createTopic(zkUtils, "t1", 1, 1,new Properties(), RackAwareMode.Enforced$.MODULE$);
- zkUtils.close();
来源: http://www.bubuko.com/infodetail-1989652.html