>From the error, I think the issue is with your zookeeperList definition.
Try changing: zookeeperList.add("http://100.12.119.10:2281"); zookeeperList.add("http://100.12.119.10:2282"); zookeeperList.add("http://100.12.119.10:2283"); to zookeeperList.add("100.12.119.10:2281"); zookeeperList.add("100.12.119.10:2282"); zookeeperList.add("100.12.119.10:2283"); If you are not using a chroot in Zookeeper then just use chrootOption = Optional.empty(); (as you have done). Intent of my code was to support both using a chroot and not using a chroot. The value of _zkChroot is read from a config file in code not shown. - Andy -