Class ConsumerConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.clients.consumer.ConsumerConfig
The consumer configuration keys
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
allow.auto.create.topics
static final String
auto.commit.interval.ms
static final String
Deprecated.static final String
auto.offset.reset
static final String
static final String
bootstrap.servers
static final String
check.crcs
static final String
client.dns.lookup
static final String
client.id
static final String
client.rack
static final String
connections.max.idle.ms
static final boolean
static final String
default.api.timeout.ms
static final String
static final boolean
static final int
static final int
static final int
static final String
static final String
static final String
static final int
static final int
static final String
enable.auto.commit
static final String
enable.metrics.push
static final String
static final String
exclude.internal.topics
static final String
fetch.max.bytes
static final String
fetch.max.wait.ms
static final String
fetch.min.bytes
static final String
group.id
static final String
group.instance.id
static final String
group.protocol
static final String
static final String
group.remote.assignor
static final String
static final String
heartbeat.interval.ms
static final String
interceptor.classes
static final String
static final String
isolation.level
static final String
static final String
key.deserializer
static final String
static final String
max.partition.fetch.bytes
static final String
max.poll.interval.ms
static final String
max.poll.records
static final String
metadata.max.age.ms
static final String
metric.reporters
static final String
metrics.num.samples
static final String
metrics.log.level
static final String
metrics.sample.window.ms
static final String
partition.assignment.strategy
static final String
receive.buffer.bytes
static final String
reconnect.backoff.max.ms
static final String
reconnect.backoff.ms
static final String
request.timeout.ms
static final String
retry.backoff.max.ms
static final String
retry.backoff.ms
static final String
security.providers
static final String
send.buffer.bytes
static final String
session.timeout.ms
static final String
socket.connection.setup.timeout.max.ms
static final String
socket.connection.setup.timeout.ms
static final String
value.deserializer
static final String
Fields inherited from class org.apache.kafka.common.config.AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG
-
Constructor Summary
ModifierConstructorDescriptionprotected
ConsumerConfig
(Map<?, ?> props, boolean doLog) ConsumerConfig
(Map<String, Object> props) ConsumerConfig
(Properties props) -
Method Summary
Modifier and TypeMethodDescriptionappendDeserializerToConfig
(Map<String, Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer) static ConfigDef
static void
postProcessParsedConfig
(Map<String, 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
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, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
-
Field Details
-
ASSIGN_FROM_SUBSCRIBED_ASSIGNORS
-
GROUP_ID_CONFIG
group.id
- See Also:
-
GROUP_INSTANCE_ID_CONFIG
group.instance.id
- See Also:
-
MAX_POLL_RECORDS_CONFIG
max.poll.records
- See Also:
-
DEFAULT_MAX_POLL_RECORDS
public static final int DEFAULT_MAX_POLL_RECORDS- See Also:
-
MAX_POLL_INTERVAL_MS_CONFIG
max.poll.interval.ms
- See Also:
-
SESSION_TIMEOUT_MS_CONFIG
session.timeout.ms
- See Also:
-
HEARTBEAT_INTERVAL_MS_CONFIG
heartbeat.interval.ms
- See Also:
-
GROUP_PROTOCOL_CONFIG
group.protocol
- See Also:
-
DEFAULT_GROUP_PROTOCOL
-
GROUP_PROTOCOL_DOC
- See Also:
-
GROUP_REMOTE_ASSIGNOR_CONFIG
group.remote.assignor
- See Also:
-
DEFAULT_GROUP_REMOTE_ASSIGNOR
-
GROUP_REMOTE_ASSIGNOR_DOC
- See Also:
-
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
- See Also:
-
CLIENT_DNS_LOOKUP_CONFIG
client.dns.lookup
- See Also:
-
ENABLE_AUTO_COMMIT_CONFIG
enable.auto.commit
- See Also:
-
AUTO_COMMIT_INTERVAL_MS_CONFIG
auto.commit.interval.ms
- See Also:
-
PARTITION_ASSIGNMENT_STRATEGY_CONFIG
partition.assignment.strategy
- See Also:
-
AUTO_OFFSET_RESET_CONFIG
auto.offset.reset
- See Also:
-
AUTO_OFFSET_RESET_DOC
- See Also:
-
FETCH_MIN_BYTES_CONFIG
fetch.min.bytes
- See Also:
-
DEFAULT_FETCH_MIN_BYTES
public static final int DEFAULT_FETCH_MIN_BYTES- See Also:
-
FETCH_MAX_BYTES_CONFIG
fetch.max.bytes
- See Also:
-
DEFAULT_FETCH_MAX_BYTES
public static final int DEFAULT_FETCH_MAX_BYTES- See Also:
-
FETCH_MAX_WAIT_MS_CONFIG
fetch.max.wait.ms
- See Also:
-
DEFAULT_FETCH_MAX_WAIT_MS
public static final int DEFAULT_FETCH_MAX_WAIT_MS- See Also:
-
METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
- See Also:
-
MAX_PARTITION_FETCH_BYTES_CONFIG
max.partition.fetch.bytes
- See Also:
-
DEFAULT_MAX_PARTITION_FETCH_BYTES
public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES- See Also:
-
SEND_BUFFER_CONFIG
send.buffer.bytes
- See Also:
-
RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
- See Also:
-
CLIENT_ID_CONFIG
client.id
- See Also:
-
CLIENT_RACK_CONFIG
client.rack
- See Also:
-
DEFAULT_CLIENT_RACK
- See Also:
-
RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
- See Also:
-
RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
- See Also:
-
RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
- See Also:
-
ENABLE_METRICS_PUSH_CONFIG
enable.metrics.push
- See Also:
-
ENABLE_METRICS_PUSH_DOC
- See Also:
-
RETRY_BACKOFF_MAX_MS_CONFIG
retry.backoff.max.ms
- See Also:
-
METRICS_SAMPLE_WINDOW_MS_CONFIG
metrics.sample.window.ms
- See Also:
-
METRICS_NUM_SAMPLES_CONFIG
metrics.num.samples
- See Also:
-
METRICS_RECORDING_LEVEL_CONFIG
metrics.log.level
- See Also:
-
METRIC_REPORTER_CLASSES_CONFIG
metric.reporters
- See Also:
-
AUTO_INCLUDE_JMX_REPORTER_CONFIG
Deprecated.auto.include.jmx.reporter
- See Also:
-
CHECK_CRCS_CONFIG
check.crcs
- See Also:
-
KEY_DESERIALIZER_CLASS_CONFIG
key.deserializer
- See Also:
-
KEY_DESERIALIZER_CLASS_DOC
- See Also:
-
VALUE_DESERIALIZER_CLASS_CONFIG
value.deserializer
- See Also:
-
VALUE_DESERIALIZER_CLASS_DOC
- See Also:
-
SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
socket.connection.setup.timeout.ms
- See Also:
-
SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
socket.connection.setup.timeout.max.ms
- See Also:
-
CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
- See Also:
-
REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
- See Also:
-
DEFAULT_API_TIMEOUT_MS_CONFIG
default.api.timeout.ms
- See Also:
-
INTERCEPTOR_CLASSES_CONFIG
interceptor.classes
- See Also:
-
INTERCEPTOR_CLASSES_DOC
- See Also:
-
EXCLUDE_INTERNAL_TOPICS_CONFIG
exclude.internal.topics
- See Also:
-
DEFAULT_EXCLUDE_INTERNAL_TOPICS
public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS- See Also:
-
ISOLATION_LEVEL_CONFIG
isolation.level
- See Also:
-
ISOLATION_LEVEL_DOC
- See Also:
-
DEFAULT_ISOLATION_LEVEL
-
ALLOW_AUTO_CREATE_TOPICS_CONFIG
allow.auto.create.topics
- See Also:
-
DEFAULT_ALLOW_AUTO_CREATE_TOPICS
public static final boolean DEFAULT_ALLOW_AUTO_CREATE_TOPICS- See Also:
-
SECURITY_PROVIDERS_CONFIG
security.providers
- See Also:
-
-
Constructor Details
-
ConsumerConfig
-
ConsumerConfig
-
ConsumerConfig
-
-
Method Details
-
postProcessParsedConfig
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 classAbstractConfig
- 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)
-
appendDeserializerToConfig
public static Map<String,Object> appendDeserializerToConfig(Map<String, Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer) -
configNames
-
configDef
-
main
-