code: private ZooKeeper createZooKeeper() throws IOException {
      ZooKeeper zk = new ZooKeeper(zkStr, sessionTimeout, wrapWatcher(this));
      for (Map.Entry<String, byte[]> authInfo : authInfos.entries()) {
        zk.addAuthInfo(authInfo.getKey(), authInfo.getValue());
      }
      return zk;
    }
docs: Creates a new ZooKeeper connection.