org.apache.kafka.common.config.AbstractConfig

org.apache.kafka.clients.producer.ProducerConfig

public class ProducerConfig
extends AbstractConfig

Configuration for the Kafka Producer. Documentation for these configurations can be found in the Kafka documentation

Field Summary

Fields
Modifier and Type	Field	Description
`static String`	`ACKS_CONFIG`	`acks`
`static String`	`BATCH_SIZE_CONFIG`	`batch.size`
`static String`	`BOOTSTRAP_SERVERS_CONFIG`	`bootstrap.servers`
`static String`	`BUFFER_MEMORY_CONFIG`	`buffer.memory`
`static String`	`CLIENT_DNS_LOOKUP_CONFIG`	`client.dns.lookup`
`static String`	`CLIENT_ID_CONFIG`	`client.id`
`static String`	`COMPRESSION_TYPE_CONFIG`	`compression.type`
`static String`	`CONNECTIONS_MAX_IDLE_MS_CONFIG`	`connections.max.idle.ms`
`static String`	`DELIVERY_TIMEOUT_MS_CONFIG`	`delivery.timeout.ms`
`static String`	`ENABLE_IDEMPOTENCE_CONFIG`	`enable.idempotence`
`static String`	`ENABLE_IDEMPOTENCE_DOC`
`static String`	`INTERCEPTOR_CLASSES_CONFIG`	`interceptor.classes`
`static String`	`INTERCEPTOR_CLASSES_DOC`
`static String`	`KEY_SERIALIZER_CLASS_CONFIG`	`key.serializer`
`static String`	`KEY_SERIALIZER_CLASS_DOC`
`static String`	`LINGER_MS_CONFIG`	`linger.ms`
`static String`	`MAX_BLOCK_MS_CONFIG`	`max.block.ms`
`static String`	`MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION`	`max.in.flight.requests.per.connection`
`static String`	`MAX_REQUEST_SIZE_CONFIG`	`max.request.size`
`static String`	`METADATA_MAX_AGE_CONFIG`	`metadata.max.age.ms`
`static String`	`METADATA_MAX_IDLE_CONFIG`	`metadata.max.idle.ms`
`static String`	`METRIC_REPORTER_CLASSES_CONFIG`	`metric.reporters`
`static String`	`METRICS_NUM_SAMPLES_CONFIG`	`metrics.num.samples`
`static String`	`METRICS_RECORDING_LEVEL_CONFIG`	`metrics.recording.level`
`static String`	`METRICS_SAMPLE_WINDOW_MS_CONFIG`	`metrics.sample.window.ms`
`static String`	`PARTITIONER_CLASS_CONFIG`	`partitioner.class`
`static String`	`RECEIVE_BUFFER_CONFIG`	`receive.buffer.bytes`
`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`	`retries`
`static String`	`RETRY_BACKOFF_MS_CONFIG`	`retry.backoff.ms`
`static String`	`SECURITY_PROVIDERS_CONFIG`	`security.providers`
`static String`	`SEND_BUFFER_CONFIG`	`send.buffer.bytes`
`static String`	`SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG`	`socket.connection.setup.timeout.max.ms`
`static String`	`SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG`	`socket.connection.setup.timeout.ms`
`static String`	`TRANSACTION_TIMEOUT_CONFIG`	`transaction.timeout.ms`
`static String`	`TRANSACTION_TIMEOUT_DOC`
`static String`	`TRANSACTIONAL_ID_CONFIG`	`transactional.id`
`static String`	`TRANSACTIONAL_ID_DOC`
`static String`	`VALUE_SERIALIZER_CLASS_CONFIG`	`value.serializer`
`static String`	`VALUE_SERIALIZER_CLASS_DOC`

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor Description

ProducerConfig(Map<String,Object> props)

ProducerConfig(Properties props)

Method Summary

Modifier and Type	Method	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).

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details
- BOOTSTRAP_SERVERS_CONFIG
  
  public static final String BOOTSTRAP_SERVERS_CONFIG
  
  bootstrap.servers
  
  See Also:
  
  Constant Field Values
- CLIENT_DNS_LOOKUP_CONFIG
  
  public static final String CLIENT_DNS_LOOKUP_CONFIG
  
  client.dns.lookup
  
  See Also:
  
  Constant Field Values
- METADATA_MAX_AGE_CONFIG
  
  public static final String METADATA_MAX_AGE_CONFIG
  
  metadata.max.age.ms
  
  See Also:
  
  Constant Field Values
- METADATA_MAX_IDLE_CONFIG
  
  public static final String METADATA_MAX_IDLE_CONFIG
  
  metadata.max.idle.ms
  
  See Also:
  
  Constant Field Values
- BATCH_SIZE_CONFIG
  
  public static final String BATCH_SIZE_CONFIG
  
  batch.size
  
  See Also:
  
  Constant Field Values
- ACKS_CONFIG
  
  public static final String ACKS_CONFIG
  
  acks
  
  See Also:
  
  Constant Field Values
- LINGER_MS_CONFIG
  
  public static final String LINGER_MS_CONFIG
  
  linger.ms
  
  See Also:
  
  Constant Field Values
- REQUEST_TIMEOUT_MS_CONFIG
  
  public static final String REQUEST_TIMEOUT_MS_CONFIG
  
  request.timeout.ms
  
  See Also:
  
  Constant Field Values
- DELIVERY_TIMEOUT_MS_CONFIG
  
  public static final String DELIVERY_TIMEOUT_MS_CONFIG
  
  delivery.timeout.ms
  
  See Also:
  
  Constant Field Values
- CLIENT_ID_CONFIG
  
  public static final String CLIENT_ID_CONFIG
  
  client.id
  
  See Also:
  
  Constant Field Values
- SEND_BUFFER_CONFIG
  
  public static final String SEND_BUFFER_CONFIG
  
  send.buffer.bytes
  
  See Also:
  
  Constant Field Values
- RECEIVE_BUFFER_CONFIG
  
  public static final String RECEIVE_BUFFER_CONFIG
  
  receive.buffer.bytes
  
  See Also:
  
  Constant Field Values
- MAX_REQUEST_SIZE_CONFIG
  
  public static final String MAX_REQUEST_SIZE_CONFIG
  
  max.request.size
  
  See Also:
  
  Constant Field Values
- RECONNECT_BACKOFF_MS_CONFIG
  
  public static final String RECONNECT_BACKOFF_MS_CONFIG
  
  reconnect.backoff.ms
  
  See Also:
  
  Constant Field Values
- RECONNECT_BACKOFF_MAX_MS_CONFIG
  
  public static final String RECONNECT_BACKOFF_MAX_MS_CONFIG
  
  reconnect.backoff.max.ms
  
  See Also:
  
  Constant Field Values
- MAX_BLOCK_MS_CONFIG
  
  public static final String MAX_BLOCK_MS_CONFIG
  
  max.block.ms
  
  See Also:
  
  Constant Field Values
- BUFFER_MEMORY_CONFIG
  
  public static final String BUFFER_MEMORY_CONFIG
  
  buffer.memory
  
  See Also:
  
  Constant Field Values
- RETRY_BACKOFF_MS_CONFIG
  
  public static final String RETRY_BACKOFF_MS_CONFIG
  
  retry.backoff.ms
  
  See Also:
  
  Constant Field Values
- COMPRESSION_TYPE_CONFIG
  
  public static final String COMPRESSION_TYPE_CONFIG
  
  compression.type
  
  See Also:
  
  Constant Field Values
- METRICS_SAMPLE_WINDOW_MS_CONFIG
  
  public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG
  
  metrics.sample.window.ms
  
  See Also:
  
  Constant Field Values
- METRICS_NUM_SAMPLES_CONFIG
  
  public static final String METRICS_NUM_SAMPLES_CONFIG
  
  metrics.num.samples
  
  See Also:
  
  Constant Field Values
- METRICS_RECORDING_LEVEL_CONFIG
  
  public static final String METRICS_RECORDING_LEVEL_CONFIG
  
  metrics.recording.level
  
  See Also:
  
  Constant Field Values
- METRIC_REPORTER_CLASSES_CONFIG
  
  public static final String METRIC_REPORTER_CLASSES_CONFIG
  
  metric.reporters
  
  See Also:
  
  Constant Field Values
- MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
  
  public static final String MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
  
  max.in.flight.requests.per.connection
  
  See Also:
  
  Constant Field Values
- RETRIES_CONFIG
  
  public static final String RETRIES_CONFIG
  
  retries
  
  See Also:
  
  Constant Field Values
- KEY_SERIALIZER_CLASS_CONFIG
  
  public static final String KEY_SERIALIZER_CLASS_CONFIG
  
  key.serializer
  
  See Also:
  
  Constant Field Values
- KEY_SERIALIZER_CLASS_DOC
  
  public static final String KEY_SERIALIZER_CLASS_DOC
  
  See Also:
  
  Constant Field Values
- VALUE_SERIALIZER_CLASS_CONFIG
  
  public static final String VALUE_SERIALIZER_CLASS_CONFIG
  
  value.serializer
  
  See Also:
  
  Constant Field Values
- VALUE_SERIALIZER_CLASS_DOC
  
  public static final String VALUE_SERIALIZER_CLASS_DOC
  
  See Also:
  
  Constant Field Values
- SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
  
  public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
  
  socket.connection.setup.timeout.ms
  
  See Also:
  
  Constant Field Values
- SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
  
  public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
  
  socket.connection.setup.timeout.max.ms
  
  See Also:
  
  Constant Field Values
- CONNECTIONS_MAX_IDLE_MS_CONFIG
  
  public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG
  
  connections.max.idle.ms
  
  See Also:
  
  Constant Field Values
- PARTITIONER_CLASS_CONFIG
  
  public static final String PARTITIONER_CLASS_CONFIG
  
  partitioner.class
  
  See Also:
  
  Constant Field Values
- INTERCEPTOR_CLASSES_CONFIG
  
  public static final String INTERCEPTOR_CLASSES_CONFIG
  
  interceptor.classes
  
  See Also:
  
  Constant Field Values
- INTERCEPTOR_CLASSES_DOC
  
  public static final String INTERCEPTOR_CLASSES_DOC
  
  See Also:
  
  Constant Field Values
- ENABLE_IDEMPOTENCE_CONFIG
  
  public static final String ENABLE_IDEMPOTENCE_CONFIG
  
  enable.idempotence
  
  See Also:
  
  Constant Field Values
- ENABLE_IDEMPOTENCE_DOC
  
  public static final String ENABLE_IDEMPOTENCE_DOC
  
  See Also:
  
  Constant Field Values
- TRANSACTION_TIMEOUT_CONFIG
  
  public static final String TRANSACTION_TIMEOUT_CONFIG
  
  transaction.timeout.ms
  
  See Also:
  
  Constant Field Values
- TRANSACTION_TIMEOUT_DOC
  
  public static final String TRANSACTION_TIMEOUT_DOC
  
  See Also:
  
  Constant Field Values
- TRANSACTIONAL_ID_CONFIG
  
  public static final String TRANSACTIONAL_ID_CONFIG
  
  transactional.id
  
  See Also:
  
  Constant Field Values
- TRANSACTIONAL_ID_DOC
  
  public static final String TRANSACTIONAL_ID_DOC
  
  See Also:
  
  Constant Field Values
- SECURITY_PROVIDERS_CONFIG
  
  public static final String SECURITY_PROVIDERS_CONFIG
  
  security.providers
  
  See Also:
  
  Constant Field Values
Constructor Details
- ProducerConfig
  
  public ProducerConfig(Properties props)
- ProducerConfig
  
  public ProducerConfig(Map<String,Object> props)
Method Details
- postProcessParsedConfig
  
  protected Map<String,Object> postProcessParsedConfig(Map<String,Object> parsedValues)
  
  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 class AbstractConfig
  
  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
  
  public static Set<String> configNames()
- configDef
  
  public static ConfigDef configDef()
- main
  
  public static void main(String[] args)

Constructor	Description
`ProducerConfig(Map<String,Object> props)`
`ProducerConfig(Properties props)`

Class ProducerConfig

Field Summary

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

Constructor Summary

Method Summary

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

Methods inherited from class java.lang.Object

Field Details

BOOTSTRAP_SERVERS_CONFIG

CLIENT_DNS_LOOKUP_CONFIG

METADATA_MAX_AGE_CONFIG

METADATA_MAX_IDLE_CONFIG

BATCH_SIZE_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

COMPRESSION_TYPE_CONFIG

METRICS_SAMPLE_WINDOW_MS_CONFIG

METRICS_NUM_SAMPLES_CONFIG

METRICS_RECORDING_LEVEL_CONFIG

METRIC_REPORTER_CLASSES_CONFIG

MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION

RETRIES_CONFIG

KEY_SERIALIZER_CLASS_CONFIG

KEY_SERIALIZER_CLASS_DOC

VALUE_SERIALIZER_CLASS_CONFIG

VALUE_SERIALIZER_CLASS_DOC

SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG

CONNECTIONS_MAX_IDLE_MS_CONFIG

PARTITIONER_CLASS_CONFIG

INTERCEPTOR_CLASSES_CONFIG

INTERCEPTOR_CLASSES_DOC

ENABLE_IDEMPOTENCE_CONFIG

ENABLE_IDEMPOTENCE_DOC

TRANSACTION_TIMEOUT_CONFIG

TRANSACTION_TIMEOUT_DOC

TRANSACTIONAL_ID_CONFIG

TRANSACTIONAL_ID_DOC

SECURITY_PROVIDERS_CONFIG

Constructor Details

ProducerConfig

ProducerConfig

Method Details

postProcessParsedConfig

configNames

configDef

main