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

ZkConfig介绍

暂无

代码示例

代码示例来源：origin: apache/samza

private ZkUtils getZkUtils(Config config, MetricsRegistry metricsRegistry, String coordinatorZkBasePath) {
 ZkConfig zkConfig = new ZkConfig(config);
 ZkKeyBuilder keyBuilder = new ZkKeyBuilder(coordinatorZkBasePath);
 ZkClient zkClient = ZkCoordinationUtilsFactory
   .createZkClient(zkConfig.getZkConnect(), zkConfig.getZkSessionTimeoutMs(), zkConfig.getZkConnectionTimeoutMs());
 return new ZkUtils(keyBuilder, zkClient, zkConfig.getZkConnectionTimeoutMs(), zkConfig.getZkSessionTimeoutMs(), metricsRegistry);
}

代码示例来源：origin: apache/samza

public String getZkConnect() {
 if (!containsKey(ZK_CONNECT)) {
  throw new ConfigException("Missing " + ZK_CONNECT + " config!");
 }
 return get(ZK_CONNECT);
}

代码示例来源：origin: apache/samza

public int getZkSessionTimeoutMs() {
 return getInt(ZK_SESSION_TIMEOUT_MS, DEFAULT_SESSION_TIMEOUT_MS);
}

代码示例来源：origin: apache/samza

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

debounceTimer.scheduleAfterDebounceTime(ZK_SESSION_ERROR, new ZkConfig(config).getZkSessionTimeoutMs(), () -> stop());
 return;
case AuthFailed:

代码示例来源：origin: apache/samza

/**
 * {@inheritDoc}
 */
@Override
public void init() {
 zkClient.waitUntilConnected(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

debounceTimer.scheduleAfterDebounceTime(ZK_SESSION_ERROR, new ZkConfig(config).getZkSessionTimeoutMs(), () -> stop());
 return;
case AuthFailed:

代码示例来源：origin: org.apache.samza/samza-core_2.12

/**
 * {@inheritDoc}
 */
@Override
public void init() {
 zkClient.waitUntilConnected(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.apache.samza/samza-core

private ZkUtils getZkUtils(Config config, MetricsRegistry metricsRegistry, String coordinatorZkBasePath) {
 ZkConfig zkConfig = new ZkConfig(config);
 ZkKeyBuilder keyBuilder = new ZkKeyBuilder(coordinatorZkBasePath);
 ZkClient zkClient = ZkCoordinationUtilsFactory
   .createZkClient(zkConfig.getZkConnect(), zkConfig.getZkSessionTimeoutMs(), zkConfig.getZkConnectionTimeoutMs());
 return new ZkUtils(keyBuilder, zkClient, zkConfig.getZkConnectionTimeoutMs(), zkConfig.getZkSessionTimeoutMs(), metricsRegistry);
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

public String getZkConnect() {
 if (!containsKey(ZK_CONNECT)) {
  throw new ConfigException("Missing " + ZK_CONNECT + " config!");
 }
 return get(ZK_CONNECT);
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

debounceTimer.scheduleAfterDebounceTime(ZK_SESSION_ERROR, new ZkConfig(config).getZkSessionTimeoutMs(), () -> stop());
 return;
case AuthFailed:

代码示例来源：origin: apache/samza

public int getZkBarrierTimeoutMs() {
  return getInt(ZK_CONSENSUS_TIMEOUT_MS, DEFAULT_CONSENSUS_TIMEOUT_MS);
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

/**
 * {@inheritDoc}
 */
@Override
public void init() {
 zkClient.waitUntilConnected(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

private ZkUtils getZkUtils(Config config, MetricsRegistry metricsRegistry, String coordinatorZkBasePath) {
 ZkConfig zkConfig = new ZkConfig(config);
 ZkKeyBuilder keyBuilder = new ZkKeyBuilder(coordinatorZkBasePath);
 ZkClient zkClient = ZkCoordinationUtilsFactory
   .createZkClient(zkConfig.getZkConnect(), zkConfig.getZkSessionTimeoutMs(), zkConfig.getZkConnectionTimeoutMs());
 return new ZkUtils(keyBuilder, zkClient, zkConfig.getZkConnectionTimeoutMs(), zkConfig.getZkSessionTimeoutMs(), metricsRegistry);
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

public String getZkConnect() {
 if (!containsKey(ZK_CONNECT)) {
  throw new ConfigException("Missing " + ZK_CONNECT + " config!");
 }
 return get(ZK_CONNECT);
}

代码示例来源：origin: org.apache.samza/samza-core

debounceTimer.scheduleAfterDebounceTime(ZK_SESSION_ERROR, new ZkConfig(config).getZkSessionTimeoutMs(), () -> stop());
 return;
case AuthFailed:

代码示例来源：origin: org.apache.samza/samza-core

public int getZkBarrierTimeoutMs() {
  return getInt(ZK_CONSENSUS_TIMEOUT_MS, DEFAULT_CONSENSUS_TIMEOUT_MS);
 }
}