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
FieldsModifier and TypeFieldDescriptionstatic final Stringacksstatic final Stringbatch.sizestatic final Stringbootstrap.serversstatic final Stringbuffer.memorystatic final Stringclient.dns.lookupstatic final Stringclient.idstatic final Stringcompression.gzip.levelstatic final Stringcompression.lz4.levelstatic final Stringcompression.typestatic final Stringcompression.zstd.levelstatic final Stringconnections.max.idle.msstatic final Stringdelivery.timeout.msstatic final Stringenable.idempotencestatic final Stringstatic final Stringenable.metrics.pushstatic final Stringstatic final Stringinterceptor.classesstatic final Stringstatic final Stringkey.serializerstatic final Stringstatic final Stringlinger.msstatic final Stringstatic final Stringstatic final Stringmax.block.msstatic final Stringmax.in.flight.requests.per.connectionstatic final Stringmax.request.sizestatic final Stringmetadata.max.age.msstatic final Stringmetadata.max.idle.msstatic final Stringmetric.reportersstatic final Stringmetrics.num.samplesstatic final Stringmetrics.recording.levelstatic final Stringmetrics.sample.window.msstatic final Stringpartitioner.adaptive.partitioning.enablestatic final Stringpartitioner.availability.timeout.msstatic final Stringpartitioner.classstatic final Stringpartitioner.ignore.keysstatic 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 Stringretriesstatic final Stringretry.backoff.max.msstatic final Stringretry.backoff.msstatic final Stringsecurity.providersstatic final Stringstatic final Stringstatic final Stringsend.buffer.bytesstatic final Stringsocket.connection.setup.timeout.max.msstatic final Stringsocket.connection.setup.timeout.msstatic final Stringtransaction.timeout.msstatic final Stringstatic final Stringtransaction.two.phase.commit.enablestatic final Stringtransactional.idstatic final Stringstatic final Stringvalue.serializerstatic final StringFields inherited from class org.apache.kafka.common.config.AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIGConstructor Summary
ConstructorsMethod Summary
Methods 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
BOOTSTRAP_SERVERS_CONFIG
CLIENT_DNS_LOOKUP_CONFIG
METADATA_MAX_AGE_CONFIG
METADATA_MAX_IDLE_CONFIG
BATCH_SIZE_CONFIG
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
ACKS_CONFIG
LINGER_MS_CONFIG
REQUEST_TIMEOUT_MS_CONFIG
DELIVERY_TIMEOUT_MS_CONFIG
CLIENT_ID_CONFIG
SEND_BUFFER_CONFIG
RECEIVE_BUFFER_CONFIG
MAX_REQUEST_SIZE_CONFIG
RECONNECT_BACKOFF_MS_CONFIG
RECONNECT_BACKOFF_MAX_MS_CONFIG
MAX_BLOCK_MS_CONFIG
BUFFER_MEMORY_CONFIG
RETRY_BACKOFF_MS_CONFIG
RETRY_BACKOFF_MAX_MS_CONFIG
ENABLE_METRICS_PUSH_CONFIG
ENABLE_METRICS_PUSH_DOC
- See Also:
COMPRESSION_TYPE_CONFIG
COMPRESSION_GZIP_LEVEL_CONFIG
COMPRESSION_LZ4_LEVEL_CONFIG
COMPRESSION_ZSTD_LEVEL_CONFIG
METRICS_SAMPLE_WINDOW_MS_CONFIG
METRICS_NUM_SAMPLES_CONFIG
METRICS_RECORDING_LEVEL_CONFIG
METRIC_REPORTER_CLASSES_CONFIG
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
max.in.flight.requests.per.connection- See Also:
RETRIES_CONFIG
KEY_SERIALIZER_CLASS_CONFIG
KEY_SERIALIZER_CLASS_DOC
- See Also:
VALUE_SERIALIZER_CLASS_CONFIG
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
SELECTABLE_PLUGIN_CLASS_CONFIG
- See Also:
SELECTABLE_PLUGIN_CLASS_DOC
- See Also:
PARTITIONER_CLASS_CONFIG
INTERCEPTOR_CLASSES_CONFIG
INTERCEPTOR_CLASSES_DOC
- See Also:
ENABLE_IDEMPOTENCE_CONFIG
ENABLE_IDEMPOTENCE_DOC
- See Also:
TRANSACTION_TIMEOUT_CONFIG
TRANSACTION_TIMEOUT_DOC
- See Also:
TRANSACTIONAL_ID_CONFIG
TRANSACTIONAL_ID_DOC
- See Also:
TRANSACTION_TWO_PHASE_COMMIT_ENABLE_CONFIG
transaction.two.phase.commit.enable- See Also:
SECURITY_PROVIDERS_CONFIG
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
ProducerConfig
ProducerConfig
Method Details
configNames
configDef
main