org.apache.kafka.clients.producer

Class ProducerConfig

java.lang.Object

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 and Description
static String	ACKS_CONFIG acks
static String	BATCH_SIZE_CONFIG batch.size
static String	BLOCK_ON_BUFFER_FULL_CONFIG Deprecated. This config will be removed in a future release. Please use MAX_BLOCK_MS_CONFIG.
static String	BOOTSTRAP_SERVERS_CONFIG bootstrap.servers
static String	BUFFER_MEMORY_CONFIG buffer.memory
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	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_FETCH_TIMEOUT_CONFIG Deprecated. This config will be removed in a future release. Please use MAX_BLOCK_MS_CONFIG
static String	METADATA_MAX_AGE_CONFIG metadata.max.age.ms
static String	METRIC_REPORTER_CLASSES_CONFIG metric.reporters
static String	METRICS_NUM_SAMPLES_CONFIG metrics.num.samples
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_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	SEND_BUFFER_CONFIG send.buffer.bytes
static String	TIMEOUT_CONFIG Deprecated. This config will be removed in a future release. Please use REQUEST_TIMEOUT_MS_CONFIG
static String	VALUE_SERIALIZER_CLASS_CONFIG value.serializer
static String	VALUE_SERIALIZER_CLASS_DOC

Method Summary

Methods

Modifier and Type	Method and Description
static Map<String,Object>	addSerializerToConfig(Map<String,Object> configs, Serializer<?> keySerializer, Serializer<?> valueSerializer)
static Properties	addSerializerToConfig(Properties properties, Serializer<?> keySerializer, Serializer<?> valueSerializer)
static void	main(String[] args)

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

equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, unused, values

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAP_SERVERS_CONFIG

public static final String BOOTSTRAP_SERVERS_CONFIG

bootstrap.servers

See Also:

Constant Field Values

METADATA_FETCH_TIMEOUT_CONFIG

@Deprecated
public static final String METADATA_FETCH_TIMEOUT_CONFIG

Deprecated. This config will be removed in a future release. Please use MAX_BLOCK_MS_CONFIG

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

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

TIMEOUT_CONFIG

@Deprecated
public static final String TIMEOUT_CONFIG

Deprecated. This config will be removed in a future release. Please use REQUEST_TIMEOUT_MS_CONFIG

See Also:

Constant Field Values

LINGER_MS_CONFIG

public static final String LINGER_MS_CONFIG

linger.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

MAX_BLOCK_MS_CONFIG

public static final String MAX_BLOCK_MS_CONFIG

max.block.ms

See Also:

Constant Field Values

BLOCK_ON_BUFFER_FULL_CONFIG

@Deprecated
public static final String BLOCK_ON_BUFFER_FULL_CONFIG

Deprecated. This config will be removed in a future release. Please use MAX_BLOCK_MS_CONFIG.

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

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

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

REQUEST_TIMEOUT_MS_CONFIG

public static final String REQUEST_TIMEOUT_MS_CONFIG

request.timeout.ms

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

Method Detail

addSerializerToConfig

public static Map<String,Object> addSerializerToConfig(Map<String,Object> configs,
                                       Serializer<?> keySerializer,
                                       Serializer<?> valueSerializer)

addSerializerToConfig

public static Properties addSerializerToConfig(Properties properties,
                               Serializer<?> keySerializer,
                               Serializer<?> valueSerializer)

main

public static void main(String[] args)