org.apache.nifi.controller.cluster

Class ZooKeeperClientConfig

java.lang.Object

org.apache.nifi.controller.cluster.ZooKeeperClientConfig

public class ZooKeeperClientConfig
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.lang.String	cleanConnectString(java.lang.String connectString) Takes a given connect string and splits it by ',' character.
static ZooKeeperClientConfig	createConfig(NiFiProperties nifiProperties)
java.lang.String	getAuthPrincipal()
java.lang.String	getAuthType()
int	getConnectionTimeoutMillis()
java.lang.String	getConnectString()
java.lang.String	getRemoveHostFromPrincipal()
java.lang.String	getRemoveRealmFromPrincipal()
java.lang.String	getRootPath()
int	getSessionTimeoutMillis()
java.lang.String	resolvePath(java.lang.String path)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getConnectString

public java.lang.String getConnectString()

getSessionTimeoutMillis

public int getSessionTimeoutMillis()

getConnectionTimeoutMillis

public int getConnectionTimeoutMillis()

getRootPath

public java.lang.String getRootPath()

getAuthType

public java.lang.String getAuthType()

getAuthPrincipal

public java.lang.String getAuthPrincipal()

getRemoveHostFromPrincipal

public java.lang.String getRemoveHostFromPrincipal()

getRemoveRealmFromPrincipal

public java.lang.String getRemoveRealmFromPrincipal()

resolvePath

public java.lang.String resolvePath(java.lang.String path)

createConfig

public static ZooKeeperClientConfig createConfig(NiFiProperties nifiProperties)

cleanConnectString

public static java.lang.String cleanConnectString(java.lang.String connectString)

Takes a given connect string and splits it by ',' character. For each split result trims whitespace then splits by ':' character. For each secondary split if a single value is returned it is trimmed and then the default zookeeper 2181 is append by adding ":2181". If two values are returned then the second value is evaluated to ensure it contains only digits and if not then the entry is in error and exception is raised. If more than two values are returned the entry is in error and an exception is raised. Each entry is trimmed and if empty the entry is skipped. After all splits are cleaned then they are all appended back together demarcated by "," and the full string is returned.

Parameters:

connectString - the string to clean

Returns:

cleaned connect string guaranteed to be non null but could be empty

Throws:

java.lang.IllegalStateException - if any portions could not be cleaned/parsed