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