本文整理了Java中org.apache.nifi.controller.cluster.ZooKeeperClientConfig.getConnectionTimeoutMillis()
方法的一些代码示例,展示了ZooKeeperClientConfig.getConnectionTimeoutMillis()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClientConfig.getConnectionTimeoutMillis()
方法的具体详情如下:
包路径:org.apache.nifi.controller.cluster.ZooKeeperClientConfig
类名称:ZooKeeperClientConfig
方法名:getConnectionTimeoutMillis
暂无
代码示例来源:origin: apache/nifi
private CuratorFramework createClient() {
// Create a new client because we don't want to try indefinitely for this to occur.
final RetryPolicy retryPolicy = new RetryNTimes(1, 100);
final CuratorACLProviderFactory aclProviderFactory = new CuratorACLProviderFactory();
final CuratorFramework client = CuratorFrameworkFactory.builder()
.connectString(zkConfig.getConnectString())
.sessionTimeoutMs(zkConfig.getSessionTimeoutMillis())
.connectionTimeoutMs(zkConfig.getConnectionTimeoutMillis())
.retryPolicy(retryPolicy)
.aclProvider(aclProviderFactory.create(zkConfig))
.defaultData(new byte[0])
.build();
client.start();
return client;
}
代码示例来源:origin: apache/nifi
zkConfig.getSessionTimeoutMillis(), zkConfig.getConnectionTimeoutMillis(), retryPolicy);
curatorClient.start();
内容来源于网络,如有侵权,请联系作者删除!