private void reconnectZooKeeper ( ) throws InterruptedException , IOException { LOG . info ( "Try to reconnect ZooKeeper " + zkQuorum ) ; if ( zooKeeper != null ) { zooKeeper . close ( ) ; } connectZooKeeper ( ) ; }
Reconnect with ZooKeeper .