本文整理了Java中kafka.zookeeper.ZooKeeperClient.waitUntilConnected()方法的一些代码示例，展示了ZooKeeperClient.waitUntilConnected()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperClient.waitUntilConnected()方法的具体详情如下：
包路径：kafka.zookeeper.ZooKeeperClient
类名称：ZooKeeperClient
方法名：waitUntilConnected

ZooKeeperClient.waitUntilConnected介绍

暂无

代码示例

代码示例来源：origin: allegro/hermes

@BeforeClass
public static void beforeZookeeperClass() throws Exception {
  zookeeperServer = new TestingServer(45678);
  zookeeperClient = CuratorFrameworkFactory.builder()
      .connectString(zookeeperServer.getConnectString())
      .retryPolicy(new ExponentialBackoffRetry(1000, 3))
      .build();
  zookeeperClient.start();
  wait = new ZookeeperWaiter(zookeeperClient);
  wait.untilZookeeperClientStarted();
  ZooKeeperClient zooKeeperClient = new ZooKeeperClient(
      zookeeperServer.getConnectString(), 60 * 1000, 15 * 1000,
      10, Time.SYSTEM, "zookeeper-test", "zookeeper-test");
  zooKeeperClient.waitUntilConnected();
  kafkaZkClient = new KafkaZkClient(zooKeeperClient, false, Time.SYSTEM);
}

代码示例来源：origin: pl.allegro.tech.hermes/hermes-test-helper

@BeforeClass
public static void beforeZookeeperClass() throws Exception {
  zookeeperServer = new TestingServer(45678);
  zookeeperClient = CuratorFrameworkFactory.builder()
      .connectString(zookeeperServer.getConnectString())
      .retryPolicy(new ExponentialBackoffRetry(1000, 3))
      .build();
  zookeeperClient.start();
  wait = new ZookeeperWaiter(zookeeperClient);
  wait.untilZookeeperClientStarted();
  ZooKeeperClient zooKeeperClient = new ZooKeeperClient(
      zookeeperServer.getConnectString(), 60 * 1000, 15 * 1000,
      10, Time.SYSTEM, "zookeeper-test", "zookeeper-test");
  zooKeeperClient.waitUntilConnected();
  kafkaZkClient = new KafkaZkClient(zooKeeperClient, false, Time.SYSTEM);
}

代码示例来源：origin: allegro/hermes

private ZooKeeperClient zooKeeperClient(KafkaProperties kafkaProperties) {
  ZooKeeperClient zooKeeperClient =  new ZooKeeperClient(
      kafkaProperties.getConnectionString(),
      kafkaProperties.getSessionTimeoutMillis(),
      kafkaProperties.getConnectionTimeoutMillis(),
      kafkaProperties.getMaxInflight(),
      Time.SYSTEM, ZOOKEEPER_METRIC_GROUP, ZOOKEEPER_METRIC_TYPE);
  zkClients.add(zooKeeperClient);
  zooKeeperClient.waitUntilConnected();
  return zooKeeperClient;
}