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

ZooKeeperClientConfig介绍

暂无

代码示例

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

public CuratorNodeProtocolSender(final SocketConfiguration socketConfig, final ProtocolContext<ProtocolMessage> protocolContext, final NiFiProperties nifiProperties) {
  super(socketConfig, protocolContext);
  zkConfig = ZooKeeperClientConfig.createConfig(nifiProperties);
  coordinatorPath = zkConfig.resolvePath("cluster/nodes/coordinator");
}

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

private SaslACLProvider(ZooKeeperClientConfig config) {
  if(!StringUtils.isEmpty(config.getAuthPrincipal())) {
    final String realm = config.getAuthPrincipal().substring(config.getAuthPrincipal().indexOf('@') + 1, config.getAuthPrincipal().length());
    final String[] user = config.getAuthPrincipal().substring(0, config.getAuthPrincipal().indexOf('@')).split("/");
    final String host = user.length == 2 ? user[1] : null;
    final String instance = user[0];
    final StringBuilder principal = new StringBuilder(instance);
    if (!config.getRemoveHostFromPrincipal().equalsIgnoreCase("true")) {
      principal.append("/");
      principal.append(host);
    }
    if (!config.getRemoveRealmFromPrincipal().equalsIgnoreCase("true")) {
      principal.append("@");
      principal.append(realm);
    }
    this.acls = Lists.newArrayList(new ACL(ZooDefs.Perms.ALL, new Id(SASL_AUTH_SCHEME, principal.toString())));
    this.acls.addAll(ZooDefs.Ids.READ_ACL_UNSAFE);
  }else{
    throw new IllegalArgumentException("No Kerberos Principal configured for use with SASL Authentication Scheme");
  }
}

代码示例来源：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

public static ZooKeeperClientConfig createConfig(final NiFiProperties nifiProperties) {
  final String connectString = nifiProperties.getProperty(NiFiProperties.ZOOKEEPER_CONNECT_STRING);
  if (connectString == null || connectString.trim().isEmpty()) {
    throw new IllegalStateException("The '" + NiFiProperties.ZOOKEEPER_CONNECT_STRING + "' property is not set in nifi.properties");
  }
  final String cleanedConnectString = cleanConnectString(connectString);
  if (cleanedConnectString.isEmpty()) {
    throw new IllegalStateException("The '" + NiFiProperties.ZOOKEEPER_CONNECT_STRING +
        "' property is set in nifi.properties but needs to be in pairs of host:port separated by commas");
  }
  final long sessionTimeoutMs = getTimePeriod(nifiProperties, NiFiProperties.ZOOKEEPER_SESSION_TIMEOUT, NiFiProperties.DEFAULT_ZOOKEEPER_SESSION_TIMEOUT);
  final long connectionTimeoutMs = getTimePeriod(nifiProperties, NiFiProperties.ZOOKEEPER_CONNECT_TIMEOUT, NiFiProperties.DEFAULT_ZOOKEEPER_CONNECT_TIMEOUT);
  final String rootPath = nifiProperties.getProperty(NiFiProperties.ZOOKEEPER_ROOT_NODE, NiFiProperties.DEFAULT_ZOOKEEPER_ROOT_NODE);
  final String authType = nifiProperties.getProperty(NiFiProperties.ZOOKEEPER_AUTH_TYPE,NiFiProperties.DEFAULT_ZOOKEEPER_AUTH_TYPE);
  final String authPrincipal = nifiProperties.getKerberosServicePrincipal();
  final String removeHostFromPrincipal = nifiProperties.getProperty(NiFiProperties.ZOOKEEPER_KERBEROS_REMOVE_HOST_FROM_PRINCIPAL,
      NiFiProperties.DEFAULT_ZOOKEEPER_KERBEROS_REMOVE_HOST_FROM_PRINCIPAL);
  final String removeRealmFromPrincipal = nifiProperties.getProperty(NiFiProperties.ZOOKEEPER_KERBEROS_REMOVE_REALM_FROM_PRINCIPAL,
      NiFiProperties.DEFAULT_ZOOKEEPER_KERBEROS_REMOVE_REALM_FROM_PRINCIPAL);
  try {
    PathUtils.validatePath(rootPath);
  } catch (final IllegalArgumentException e) {
    throw new IllegalArgumentException("The '" + NiFiProperties.ZOOKEEPER_ROOT_NODE + "' property in nifi.properties is set to an illegal value: " + rootPath);
  }
  return new ZooKeeperClientConfig(cleanedConnectString, (int) sessionTimeoutMs, (int) connectionTimeoutMs, rootPath, authType, authPrincipal, removeHostFromPrincipal, removeRealmFromPrincipal);
}

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

public CuratorLeaderElectionManager(final int threadPoolSize, final NiFiProperties properties) {
  leaderElectionMonitorEngine = new FlowEngine(threadPoolSize, "Leader Election Notification", true);
  zkConfig = ZooKeeperClientConfig.createConfig(properties);
}

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

public ACLProvider create(ZooKeeperClientConfig config){
  return StringUtils.equalsIgnoreCase(config.getAuthType(),SASL_AUTH_SCHEME) ? new SaslACLProvider(config) : new DefaultACLProvider();
}

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

final CuratorFramework curatorClient = CuratorFrameworkFactory.newClient(zkConfig.getConnectString(),
    zkConfig.getSessionTimeoutMillis(), zkConfig.getConnectionTimeoutMillis(), retryPolicy);
curatorClient.start();