public  ZooKeeper initZk(){

         final CountDownLatch countDownLatch = new CountDownLatch(1);

         ZooKeeper zk = null;

         try {

             zk = new ZooKeeper("127.0.0.1:2181", 3000, new Watcher() {

                 @Override

                 public void process(WatchedEvent watchedEvent) {

                     if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {

                         countDownLatch.countDown();

                     }

                     System.out.println("Watch =>" + watchedEvent.getType());

                 }

             });

             countDownLatch.await();

         } catch (IOException e) {

             e.printStackTrace();

         } catch (InterruptedException e) {

             e.printStackTrace();

         }

         return  zk;

     }