public class AdminClientConfig extends AbstractConfig
Modifier and Type | Field and Description |
---|---|
static String |
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers |
static String |
CLIENT_DNS_LOOKUP_CONFIG
client.dns.lookup |
static String |
CLIENT_ID_CONFIG |
static String |
CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms |
static String |
DEFAULT_SECURITY_PROTOCOL |
static String |
METADATA_MAX_AGE_CONFIG |
static String |
METRIC_REPORTER_CLASSES_CONFIG |
static String |
METRICS_NUM_SAMPLES_CONFIG |
static String |
METRICS_RECORDING_LEVEL_CONFIG |
static String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
static String |
RECEIVE_BUFFER_CONFIG |
static String |
RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms |
static String |
RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms |
static String |
REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms |
static String |
RETRIES_CONFIG |
static String |
RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms |
static String |
SECURITY_PROTOCOL_CONFIG |
static String |
SEND_BUFFER_CONFIG |
Modifier | Constructor and Description |
---|---|
|
AdminClientConfig(Map<?,?> props) |
protected |
AdminClientConfig(Map<?,?> props,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
static ConfigDef |
configDef() |
static Set<String> |
configNames() |
static void |
main(String[] args) |
protected Map<String,Object> |
postProcessParsedConfig(Map<String,Object> parsedValues)
Called directly after user configs got parsed (and thus default values got set).
|
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
public static final String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final String CLIENT_DNS_LOOKUP_CONFIG
client.dns.lookup
public static final String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final String RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
public static final String RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final String CLIENT_ID_CONFIG
public static final String METADATA_MAX_AGE_CONFIG
public static final String SEND_BUFFER_CONFIG
public static final String RECEIVE_BUFFER_CONFIG
public static final String METRIC_REPORTER_CLASSES_CONFIG
public static final String METRICS_NUM_SAMPLES_CONFIG
public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG
public static final String METRICS_RECORDING_LEVEL_CONFIG
public static final String SECURITY_PROTOCOL_CONFIG
public static final String DEFAULT_SECURITY_PROTOCOL
public static final String RETRIES_CONFIG
public AdminClientConfig(Map<?,?> props)
protected AdminClientConfig(Map<?,?> props, boolean doLog)
protected Map<String,Object> postProcessParsedConfig(Map<String,Object> parsedValues)
AbstractConfig
postProcessParsedConfig
in class AbstractConfig
parsedValues
- unmodifiable map of current configurationpublic static ConfigDef configDef()
public static void main(String[] args)