code: private void reconnectZooKeeper() throws InterruptedException, IOException {
      LOG.info("Try to reconnect ZooKeeper " + zkQuorum);
      
      if (zooKeeper != null) {
        zooKeeper.close();
      }
      connectZooKeeper();
    }
docs: Reconnect with ZooKeeper.
  
  @throws InterruptedException when interrupt close ZooKeeper object
  @throws IOException when error to connect with ZooKeeper