public void createNewZKConnection() throws IOException {
    Watcher watcher = new Watcher() {
      @Override
      public void process(WatchedEvent watchedEvent) {
        LOG.info("Created ZooKeeper Connection For executing task");
      }
    };

    this.zk = new ZooKeeper(quorum, SESSION_TIMEOUT_ZK, watcher);
  }
Creates connection with ZooKeeper
@throws IOException when not able to create connection properly
hbase-it/src/test/java/org/apache/hadoop/hbase/ChaosZKClient.java