public class AegisConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BROKER_ENDPOINTS_CONFIG |
static java.lang.String |
BROKER_ENDPOINTS_DOC |
static java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_CONFIG |
static java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT |
static java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_DOC |
static java.lang.String |
NUM_WORKER_POOL_THREADS_CONFIG |
static int |
NUM_WORKER_POOL_THREADS_DEFAULT |
static java.lang.String |
NUM_WORKER_POOL_THREADS_DOC |
static java.lang.String |
TENANT_ENDPOINTS_CONFIG |
static java.lang.String |
TENANT_ENDPOINTS_DOC |
Modifier | Constructor and Description |
---|---|
|
AegisConfig(java.util.Map<?,?> props) |
protected |
AegisConfig(java.util.Map<?,?> props,
boolean doLog) |
|
AegisConfig(java.util.Properties props) |
|
AegisConfig(java.lang.String... keyValuePairs)
Initialize an AegisConfig based on some key/value pairs.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Set<java.lang.String> |
configNames() |
java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> |
listenerSecurityProtocolMap()
Returns a map of listener names to security protocols.
|
static void |
main(java.lang.String[] args) |
protected java.util.Map<java.lang.String,java.lang.Object> |
postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues) |
AegisConfig |
resolveListenerConfig(java.lang.String listenerName)
Get the configuration for a particular listener.
|
java.util.Set<java.lang.String> |
unused() |
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String LISTENER_SECURITY_PROTOCOL_MAP_CONFIG
public static final java.lang.String LISTENER_SECURITY_PROTOCOL_MAP_DOC
public static final java.lang.String LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT
public static final java.lang.String TENANT_ENDPOINTS_CONFIG
public static final java.lang.String TENANT_ENDPOINTS_DOC
public static final java.lang.String BROKER_ENDPOINTS_CONFIG
public static final java.lang.String BROKER_ENDPOINTS_DOC
public static final java.lang.String NUM_WORKER_POOL_THREADS_CONFIG
public static final java.lang.String NUM_WORKER_POOL_THREADS_DOC
public static final int NUM_WORKER_POOL_THREADS_DEFAULT
public AegisConfig(java.util.Properties props)
public AegisConfig(java.util.Map<?,?> props)
public AegisConfig(java.lang.String... keyValuePairs)
keyValuePairs
- An array in the form of alternating keys and values.
Example: key1, value1, key2, value2, ...protected AegisConfig(java.util.Map<?,?> props, boolean doLog)
protected java.util.Map<java.lang.String,java.lang.Object> postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues)
postProcessParsedConfig
in class org.apache.kafka.common.config.AbstractConfig
public AegisConfig resolveListenerConfig(java.lang.String listenerName)
listenerName
- The name of the listener.public static java.util.Set<java.lang.String> configNames()
public java.util.Set<java.lang.String> unused()
unused
in class org.apache.kafka.common.config.AbstractConfig
public java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> listenerSecurityProtocolMap()
public static void main(java.lang.String[] args)