Skip to content

Commit

Permalink
getting ZkUtils from apply method
Browse files Browse the repository at this point in the history
  • Loading branch information
amitB10 committed Aug 24, 2016
1 parent fa9b43c commit bcdd952
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -237,8 +237,7 @@ private static void createTopics(List<String> topics, int partitions,
String zkConfig) throws InterruptedException {

ZkClient zkClient = createZkClient(zkConfig);
//ZkUtils zkUtils = ZkUtils.apply(zkClient, false);
ZkUtils zkUtils = new ZkUtils(zkClient, null, false);
ZkUtils zkUtils = ZkUtils.apply(zkClient, false);

try {
Properties props = new Properties();
Expand Down

0 comments on commit bcdd952

Please sign in to comment.