org.apache.kafka.clients.admin

Class AdminClientConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.kafka.clients.admin.AdminClientConfig

public class AdminClientConfig
extends AbstractConfig

The AdminClient configuration class, which also contains constants for configuration entry names.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BOOTSTRAP_SERVERS_CONFIG bootstrap.servers
static java.lang.String	CLIENT_DNS_LOOKUP_CONFIG client.dns.lookup
static java.lang.String	CLIENT_ID_CONFIG
static java.lang.String	CONNECTIONS_MAX_IDLE_MS_CONFIG connections.max.idle.ms
static java.lang.String	DEFAULT_SECURITY_PROTOCOL
static java.lang.String	METADATA_MAX_AGE_CONFIG
static java.lang.String	METRIC_REPORTER_CLASSES_CONFIG
static java.lang.String	METRICS_NUM_SAMPLES_CONFIG
static java.lang.String	METRICS_RECORDING_LEVEL_CONFIG
static java.lang.String	METRICS_SAMPLE_WINDOW_MS_CONFIG
static java.lang.String	RECEIVE_BUFFER_CONFIG
static java.lang.String	RECONNECT_BACKOFF_MAX_MS_CONFIG reconnect.backoff.max.ms
static java.lang.String	RECONNECT_BACKOFF_MS_CONFIG reconnect.backoff.ms
static java.lang.String	REQUEST_TIMEOUT_MS_CONFIG request.timeout.ms
static java.lang.String	RETRIES_CONFIG
static java.lang.String	RETRY_BACKOFF_MS_CONFIG retry.backoff.ms
static java.lang.String	SECURITY_PROTOCOL_CONFIG
static java.lang.String	SEND_BUFFER_CONFIG

Constructor Summary

Constructors

Modifier	Constructor and Description
	AdminClientConfig(java.util.Map<?,?> props)
protected	AdminClientConfig(java.util.Map<?,?> props, boolean doLog)

Method Summary

Modifier and Type	Method and Description
static java.util.Set<java.lang.String>	configNames()
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) Called directly after user configs got parsed (and thus default values got set).

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAP_SERVERS_CONFIG

public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG

bootstrap.servers

See Also:

Constant Field Values

CLIENT_DNS_LOOKUP_CONFIG

public static final java.lang.String CLIENT_DNS_LOOKUP_CONFIG

client.dns.lookup

See Also:

Constant Field Values

RECONNECT_BACKOFF_MS_CONFIG

public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG

reconnect.backoff.ms

See Also:

Constant Field Values

RECONNECT_BACKOFF_MAX_MS_CONFIG

public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG

reconnect.backoff.max.ms

See Also:

Constant Field Values

RETRY_BACKOFF_MS_CONFIG

public static final java.lang.String RETRY_BACKOFF_MS_CONFIG

retry.backoff.ms

See Also:

Constant Field Values

CONNECTIONS_MAX_IDLE_MS_CONFIG

public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG

connections.max.idle.ms

See Also:

Constant Field Values

REQUEST_TIMEOUT_MS_CONFIG

public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG

request.timeout.ms

See Also:

Constant Field Values

CLIENT_ID_CONFIG

public static final java.lang.String CLIENT_ID_CONFIG

See Also:

Constant Field Values

METADATA_MAX_AGE_CONFIG

public static final java.lang.String METADATA_MAX_AGE_CONFIG

See Also:

Constant Field Values

SEND_BUFFER_CONFIG

public static final java.lang.String SEND_BUFFER_CONFIG

See Also:

Constant Field Values

RECEIVE_BUFFER_CONFIG

public static final java.lang.String RECEIVE_BUFFER_CONFIG

See Also:

Constant Field Values

METRIC_REPORTER_CLASSES_CONFIG

public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG

See Also:

Constant Field Values

METRICS_NUM_SAMPLES_CONFIG

public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG

See Also:

Constant Field Values

METRICS_SAMPLE_WINDOW_MS_CONFIG

public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG

See Also:

Constant Field Values

METRICS_RECORDING_LEVEL_CONFIG

public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG

See Also:

Constant Field Values

SECURITY_PROTOCOL_CONFIG

public static final java.lang.String SECURITY_PROTOCOL_CONFIG

See Also:

Constant Field Values

DEFAULT_SECURITY_PROTOCOL

public static final java.lang.String DEFAULT_SECURITY_PROTOCOL

See Also:

Constant Field Values

RETRIES_CONFIG

public static final java.lang.String RETRIES_CONFIG

See Also:

Constant Field Values

Constructor Detail

AdminClientConfig

public AdminClientConfig(java.util.Map<?,?> props)

AdminClientConfig

protected AdminClientConfig(java.util.Map<?,?> props,
                            boolean doLog)

Method Detail

postProcessParsedConfig

protected java.util.Map<java.lang.String,java.lang.Object> postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues)

Description copied from class: AbstractConfig

Called directly after user configs got parsed (and thus default values got set). This allows to change default values for "secondary defaults" if required.

Overrides:

postProcessParsedConfig in class AbstractConfig

Parameters:

parsedValues - unmodifiable map of current configuration

Returns:

a map of updates that should be applied to the configuration (will be validated to prevent bad updates)

configNames

public static java.util.Set<java.lang.String> configNames()

main

public static void main(java.lang.String[] args)