Class ConsumerConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.clients.consumer.ConsumerConfig
The consumer configuration keys
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringallow.auto.create.topicsstatic final Stringauto.commit.interval.msstatic final Stringauto.offset.resetstatic final Stringstatic final Stringbootstrap.serversstatic final Stringcheck.crcsstatic final Stringclient.dns.lookupstatic final Stringclient.idstatic final Stringclient.rackstatic final Stringconnections.max.idle.msstatic final booleanstatic final Stringdefault.api.timeout.msstatic final Stringstatic final booleanstatic final intstatic final intstatic final intstatic final Stringstatic final Stringstatic final Stringstatic final intstatic final intstatic final Stringstatic final Stringenable.auto.commitstatic final Stringenable.metrics.pushstatic final Stringstatic final Stringexclude.internal.topicsstatic final Stringfetch.max.bytesstatic final Stringfetch.max.wait.msstatic final Stringfetch.min.bytesstatic final Stringgroup.idstatic final Stringgroup.instance.idstatic final Stringgroup.protocolstatic final Stringstatic final Stringgroup.remote.assignorstatic final Stringstatic final Stringheartbeat.interval.msstatic final Stringinterceptor.classesstatic final Stringstatic final Stringstatic final Stringisolation.levelstatic final Stringstatic final Stringkey.deserializerstatic final Stringstatic final Stringstatic final Stringstatic final Stringmax.partition.fetch.bytesstatic final Stringmax.poll.interval.msstatic final Stringmax.poll.recordsstatic final Stringmetadata.max.age.msstatic final Stringmetric.reportersstatic final Stringmetrics.num.samplesstatic final Stringmetrics.log.levelstatic final Stringmetrics.sample.window.msstatic final Stringpartition.assignment.strategystatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringreceive.buffer.bytesstatic final Stringreconnect.backoff.max.msstatic final Stringreconnect.backoff.msstatic final Stringrequest.timeout.msstatic final Stringretry.backoff.max.msstatic final Stringretry.backoff.msstatic final Stringsecurity.providersstatic final Stringstatic final Stringstatic final Stringsend.buffer.bytesstatic final Stringsession.timeout.msstatic final Stringshare.acknowledgement.modestatic final Stringshare.acquire.modestatic final Stringsocket.connection.setup.timeout.max.msstatic final Stringsocket.connection.setup.timeout.msstatic final Stringvalue.deserializerstatic final StringFields inherited from class org.apache.kafka.common.config.AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOCConstructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionappendDeserializerToConfig(Map<String, Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer) static ConfigDefstatic voidMethods inherited from class org.apache.kafka.common.config.AbstractConfig
documentationOf, equals, 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_INSTANCE_ID_CONFIG
MAX_POLL_RECORDS_CONFIG
DEFAULT_MAX_POLL_RECORDS
public static final int DEFAULT_MAX_POLL_RECORDS- See Also:
MAX_POLL_INTERVAL_MS_CONFIG
SESSION_TIMEOUT_MS_CONFIG
HEARTBEAT_INTERVAL_MS_CONFIG
GROUP_PROTOCOL_CONFIG
DEFAULT_GROUP_PROTOCOL
GROUP_PROTOCOL_DOC
- See Also:
GROUP_REMOTE_ASSIGNOR_CONFIG
DEFAULT_GROUP_REMOTE_ASSIGNOR
GROUP_REMOTE_ASSIGNOR_DOC
- See Also:
BOOTSTRAP_SERVERS_CONFIG
CLIENT_DNS_LOOKUP_CONFIG
ENABLE_AUTO_COMMIT_CONFIG
AUTO_COMMIT_INTERVAL_MS_CONFIG
PARTITION_ASSIGNMENT_STRATEGY_CONFIG
partition.assignment.strategy- See Also:
AUTO_OFFSET_RESET_CONFIG
AUTO_OFFSET_RESET_DOC
- See Also:
FETCH_MIN_BYTES_CONFIG
DEFAULT_FETCH_MIN_BYTES
public static final int DEFAULT_FETCH_MIN_BYTES- See Also:
FETCH_MAX_BYTES_CONFIG
DEFAULT_FETCH_MAX_BYTES
public static final int DEFAULT_FETCH_MAX_BYTES- See Also:
FETCH_MAX_WAIT_MS_CONFIG
DEFAULT_FETCH_MAX_WAIT_MS
public static final int DEFAULT_FETCH_MAX_WAIT_MS- See Also:
METADATA_MAX_AGE_CONFIG
MAX_PARTITION_FETCH_BYTES_CONFIG
DEFAULT_MAX_PARTITION_FETCH_BYTES
public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES- See Also:
SEND_BUFFER_CONFIG
RECEIVE_BUFFER_CONFIG
CLIENT_ID_CONFIG
CLIENT_RACK_CONFIG
DEFAULT_CLIENT_RACK
- See Also:
RECONNECT_BACKOFF_MS_CONFIG
RECONNECT_BACKOFF_MAX_MS_CONFIG
RETRY_BACKOFF_MS_CONFIG
ENABLE_METRICS_PUSH_CONFIG
ENABLE_METRICS_PUSH_DOC
- See Also:
RETRY_BACKOFF_MAX_MS_CONFIG
METRICS_SAMPLE_WINDOW_MS_CONFIG
METRICS_NUM_SAMPLES_CONFIG
METRICS_RECORDING_LEVEL_CONFIG
METRIC_REPORTER_CLASSES_CONFIG
CHECK_CRCS_CONFIG
KEY_DESERIALIZER_CLASS_CONFIG
KEY_DESERIALIZER_CLASS_DOC
- See Also:
VALUE_DESERIALIZER_CLASS_CONFIG
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
REQUEST_TIMEOUT_MS_CONFIG
DEFAULT_API_TIMEOUT_MS_CONFIG
SELECTABLE_PLUGIN_CLASS_CONFIG
- See Also:
SELECTABLE_PLUGIN_CLASS_DOC
- See Also:
INTERCEPTOR_CLASSES_CONFIG
INTERCEPTOR_CLASSES_DOC
- See Also:
EXCLUDE_INTERNAL_TOPICS_CONFIG
DEFAULT_EXCLUDE_INTERNAL_TOPICS
public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS- See Also:
ISOLATION_LEVEL_CONFIG
ISOLATION_LEVEL_DOC
- See Also:
DEFAULT_ISOLATION_LEVEL
ALLOW_AUTO_CREATE_TOPICS_CONFIG
DEFAULT_ALLOW_AUTO_CREATE_TOPICS
public static final boolean DEFAULT_ALLOW_AUTO_CREATE_TOPICS- See Also:
SECURITY_PROVIDERS_CONFIG
SHARE_ACKNOWLEDGEMENT_MODE_CONFIG
INTERNAL_SHARE_ACKNOWLEDGEMENT_MODE_CONFIG
- See Also:
SHARE_ACQUIRE_MODE_CONFIG
DEFAULT_SHARE_ACQUIRE_MODE
PROXY_PROTOCOL_CLIENT_VERSION
- See Also:
PROXY_PROTOCOL_CLIENT_VERSION_DOC
- See Also:
PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT
PROXY_PROTOCOL_CLIENT_ADDRESS
- See Also:
PROXY_PROTOCOL_CLIENT_ADDRESS_DOC
- See Also:
PROXY_PROTOCOL_CLIENT_PORT
- See Also:
PROXY_PROTOCOL_CLIENT_PORT_DOC
- See Also:
PROXY_PROTOCOL_CLIENT_MODE
- See Also:
PROXY_PROTOCOL_CLIENT_MODE_DOC
PROXY_PROTOCOL_CLIENT_MODE_DEFAULT
LKC_ID
- See Also:
LKC_ID_DOC
Constructor Details
ConsumerConfig
ConsumerConfig
Method Details
appendDeserializerToConfig
public static Map<String,Object> appendDeserializerToConfig(Map<String, Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer) configNames
configDef
main