Class ProducerConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.clients.producer.ProducerConfig
Configuration for the Kafka Producer. Documentation for these configurations can be found in the Kafka documentation
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
acks
static final String
Deprecated.static final String
batch.size
static final String
bootstrap.servers
static final String
buffer.memory
static final String
client.dns.lookup
static final String
client.id
static final String
compression.type
static final String
connections.max.idle.ms
static final String
delivery.timeout.ms
static final String
enable.idempotence
static final String
static final String
interceptor.classes
static final String
static final String
key.serializer
static final String
static final String
linger.ms
static final String
max.block.ms
static final String
max.in.flight.requests.per.connection
static final String
max.request.size
static final String
metadata.max.age.ms
static final String
metadata.max.idle.ms
static final String
metric.reporters
static final String
metrics.num.samples
static final String
metrics.recording.level
static final String
metrics.sample.window.ms
static final String
partitioner.adaptive.partitioning.enable
static final String
partitioner.availability.timeout.ms
static final String
partitioner.class
static final String
partitioner.ignore.keys
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
retries
static final String
retry.backoff.ms
static final String
security.providers
static final String
send.buffer.bytes
static final String
socket.connection.setup.timeout.max.ms
static final String
socket.connection.setup.timeout.ms
static final String
transaction.timeout.ms
static final String
static final String
transactional.id
static final String
static final String
value.serializer
static final String
Fields inherited from class org.apache.kafka.common.config.AbstractConfig
CONFIG_PROVIDERS_CONFIG
-
Constructor Summary
-
Method Summary
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
-
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
- See Also:
-
CLIENT_DNS_LOOKUP_CONFIG
client.dns.lookup
- See Also:
-
METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
- See Also:
-
METADATA_MAX_IDLE_CONFIG
metadata.max.idle.ms
- See Also:
-
BATCH_SIZE_CONFIG
batch.size
- See Also:
-
PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG
partitioner.adaptive.partitioning.enable
- See Also:
-
PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG
partitioner.availability.timeout.ms
- See Also:
-
PARTITIONER_IGNORE_KEYS_CONFIG
partitioner.ignore.keys
- See Also:
-
ACKS_CONFIG
acks
- See Also:
-
LINGER_MS_CONFIG
linger.ms
- See Also:
-
REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
- See Also:
-
DELIVERY_TIMEOUT_MS_CONFIG
delivery.timeout.ms
- See Also:
-
CLIENT_ID_CONFIG
client.id
- See Also:
-
SEND_BUFFER_CONFIG
send.buffer.bytes
- See Also:
-
RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
- See Also:
-
MAX_REQUEST_SIZE_CONFIG
max.request.size
- See Also:
-
RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
- See Also:
-
RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
- See Also:
-
MAX_BLOCK_MS_CONFIG
max.block.ms
- See Also:
-
BUFFER_MEMORY_CONFIG
buffer.memory
- See Also:
-
RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
- See Also:
-
COMPRESSION_TYPE_CONFIG
compression.type
- 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.recording.level
- See Also:
-
METRIC_REPORTER_CLASSES_CONFIG
metric.reporters
- See Also:
-
AUTO_INCLUDE_JMX_REPORTER_CONFIG
Deprecated.auto.include.jmx.reporter
- See Also:
-
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
max.in.flight.requests.per.connection
- See Also:
-
RETRIES_CONFIG
retries
- See Also:
-
KEY_SERIALIZER_CLASS_CONFIG
key.serializer
- See Also:
-
KEY_SERIALIZER_CLASS_DOC
- See Also:
-
VALUE_SERIALIZER_CLASS_CONFIG
value.serializer
- See Also:
-
VALUE_SERIALIZER_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:
-
PARTITIONER_CLASS_CONFIG
partitioner.class
- See Also:
-
INTERCEPTOR_CLASSES_CONFIG
interceptor.classes
- See Also:
-
INTERCEPTOR_CLASSES_DOC
- See Also:
-
ENABLE_IDEMPOTENCE_CONFIG
enable.idempotence
- See Also:
-
ENABLE_IDEMPOTENCE_DOC
- See Also:
-
TRANSACTION_TIMEOUT_CONFIG
transaction.timeout.ms
- See Also:
-
TRANSACTION_TIMEOUT_DOC
- See Also:
-
TRANSACTIONAL_ID_CONFIG
transactional.id
- See Also:
-
TRANSACTIONAL_ID_DOC
- See Also:
-
SECURITY_PROVIDERS_CONFIG
security.providers
- See Also:
-
-
Constructor Details
-
ProducerConfig
-
ProducerConfig
-
-
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)
-
configNames
-
configDef
-
main
-