code: protected CuratorFramework createZKClient() {
          val serviceConfig = getServiceConfig();
          CuratorFramework zkClient = CuratorFrameworkFactory
                  .builder()
                  .connectString(serviceConfig.getZkURL())
                  .namespace("pravega/" + serviceConfig.getClusterName())
                  .retryPolicy(new ExponentialBackoffRetry(serviceConfig.getZkRetrySleepMs(), serviceConfig.getZkRetryCount()))
                  .sessionTimeoutMs(serviceConfig.getZkSessionTimeoutMs())
                  .build();
          zkClient.start();
          return zkClient;
      }
docs: Creates a new instance of the CuratorFramework class using configuration from the shared AdminCommandState.