public class AdminClientConfig extends AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers |
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 and Description |
---|
AdminClientConfig(java.util.Map<?,?> props) |
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).
|
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixOverride
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
public static final java.lang.String RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final java.lang.String CLIENT_ID_CONFIG
public static final java.lang.String METADATA_MAX_AGE_CONFIG
public static final java.lang.String SEND_BUFFER_CONFIG
public static final java.lang.String RECEIVE_BUFFER_CONFIG
public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG
public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG
public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG
public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG
public static final java.lang.String SECURITY_PROTOCOL_CONFIG
public static final java.lang.String DEFAULT_SECURITY_PROTOCOL
public static final java.lang.String RETRIES_CONFIG
protected java.util.Map<java.lang.String,java.lang.Object> postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues)
AbstractConfig
postProcessParsedConfig
in class AbstractConfig
parsedValues
- unmodifiable map of current configurationpublic static java.util.Set<java.lang.String> configNames()
public static void main(java.lang.String[] args)