private void createZKConnection(Watcher watcher) throws IOException {
    if (watcher == null) {
      zk = new ZooKeeper(quorum, ChaosConstants.SESSION_TIMEOUT_ZK, this);
    } else {
      zk = new ZooKeeper(quorum, ChaosConstants.SESSION_TIMEOUT_ZK, watcher);
    }
    LOG.info("ZooKeeper Connection created for ChaosAgent: " + agentName);
  }
Creates Connection with ZooKeeper.
@throws IOException if something goes wrong
hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/ChaosAgent.java