public class ProducerConfig
extends org.apache.kafka.common.config.AbstractConfig
DatabusProducer
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACKS_CONFIG
acks |
static java.lang.String |
BATCH_SIZE_CONFIG
batch.size |
static java.lang.String |
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers |
static java.lang.String |
BUFFER_MEMORY_CONFIG
buffer.memory |
static java.lang.String |
CLIENT_ID_CONFIG
client.id |
static java.lang.String |
COMPRESSION_TYPE_CONFIG
compression.type |
static java.lang.String |
CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms |
static java.lang.String |
ENABLE_IDEMPOTENCE_CONFIG
enable.idempotence |
static java.lang.String |
ENABLE_IDEMPOTENCE_DOC |
static java.lang.String |
INTERCEPTOR_CLASSES_CONFIG
interceptor.classes |
static java.lang.String |
INTERCEPTOR_CLASSES_DOC |
static java.lang.String |
KEY_SERIALIZER_CLASS_CONFIG
key.serializer |
static java.lang.String |
KEY_SERIALIZER_CLASS_DOC |
static java.lang.String |
LINGER_MS_CONFIG
linger.ms |
static java.lang.String |
MAX_BLOCK_MS_CONFIG
max.block.ms |
static java.lang.String |
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
max.in.flight.requests.per.connection |
static java.lang.String |
MAX_REQUEST_SIZE_CONFIG
max.request.size |
static java.lang.String |
METADATA_MAX_AGE_CONFIG
metadata.max.age.ms |
static java.lang.String |
METRIC_REPORTER_CLASSES_CONFIG
metric.reporters |
static java.lang.String |
METRICS_NUM_SAMPLES_CONFIG
metrics.num.samples |
static java.lang.String |
METRICS_RECORDING_LEVEL_CONFIG
metrics.log.level |
static java.lang.String |
METRICS_SAMPLE_WINDOW_MS_CONFIG
metrics.sample.window.ms |
static java.lang.String |
PARTITIONER_CLASS_CONFIG
partitioner.class |
static java.lang.String |
RECEIVE_BUFFER_CONFIG
receive.buffer.bytes |
static java.lang.String |
RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms |
static java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms |
static java.lang.String |
REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms |
static java.lang.String |
RETRIES_CONFIG
retries |
static java.lang.String |
RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms |
static java.lang.String |
SEND_BUFFER_CONFIG
send.buffer.bytes |
static java.lang.String |
TRANSACTION_TIMEOUT_CONFIG
transaction.timeout.ms |
static java.lang.String |
TRANSACTION_TIMEOUT_DOC |
static java.lang.String |
TRANSACTIONAL_ID_CONFIG
transactional.id |
static java.lang.String |
TRANSACTIONAL_ID_DOC |
static java.lang.String |
VALUE_SERIALIZER_CLASS_CONFIG
value.serializer |
static java.lang.String |
VALUE_SERIALIZER_CLASS_DOC |
Constructor and Description |
---|
ProducerConfig(java.util.Map<java.lang.String,java.lang.Object> props)
ProducerConfig constructor
|
ProducerConfig(java.util.Properties props)
ProducerConfig constructor
|
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
addSerializerToConfig(java.util.Map<java.lang.String,java.lang.Object> configs,
org.apache.kafka.common.serialization.Serializer<?> keySerializer,
org.apache.kafka.common.serialization.Serializer<?> valueSerializer)
Adds a serializer object to the config map
|
static java.util.Properties |
addSerializerToConfig(java.util.Properties properties,
org.apache.kafka.common.serialization.Serializer<?> keySerializer,
org.apache.kafka.common.serialization.Serializer<?> valueSerializer)
Adds a serializer object to the Properties map
|
static java.util.Set<java.lang.String> |
configNames()
Gets the config names
|
static void |
main(java.lang.String[] args) |
equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final java.lang.String METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
public static final java.lang.String BATCH_SIZE_CONFIG
batch.size
public static final java.lang.String ACKS_CONFIG
acks
public static final java.lang.String LINGER_MS_CONFIG
linger.ms
public static final java.lang.String CLIENT_ID_CONFIG
client.id
public static final java.lang.String SEND_BUFFER_CONFIG
send.buffer.bytes
public static final java.lang.String RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
public static final java.lang.String MAX_REQUEST_SIZE_CONFIG
max.request.size
public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG
reconnect.backoff.max.ms
public static final java.lang.String MAX_BLOCK_MS_CONFIG
max.block.ms
public static final java.lang.String BUFFER_MEMORY_CONFIG
buffer.memory
public static final java.lang.String RETRY_BACKOFF_MS_CONFIG
retry.backoff.ms
public static final java.lang.String COMPRESSION_TYPE_CONFIG
compression.type
public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG
metrics.sample.window.ms
public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG
metrics.num.samples
public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG
metrics.log.level
public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG
metric.reporters
public static final java.lang.String MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION
max.in.flight.requests.per.connection
public static final java.lang.String RETRIES_CONFIG
retries
public static final java.lang.String KEY_SERIALIZER_CLASS_CONFIG
key.serializer
public static final java.lang.String KEY_SERIALIZER_CLASS_DOC
public static final java.lang.String VALUE_SERIALIZER_CLASS_CONFIG
value.serializer
public static final java.lang.String VALUE_SERIALIZER_CLASS_DOC
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final java.lang.String PARTITIONER_CLASS_CONFIG
partitioner.class
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final java.lang.String INTERCEPTOR_CLASSES_CONFIG
interceptor.classes
public static final java.lang.String INTERCEPTOR_CLASSES_DOC
public static final java.lang.String ENABLE_IDEMPOTENCE_CONFIG
enable.idempotence
public static final java.lang.String ENABLE_IDEMPOTENCE_DOC
public static final java.lang.String TRANSACTION_TIMEOUT_CONFIG
transaction.timeout.ms
public static final java.lang.String TRANSACTION_TIMEOUT_DOC
public static final java.lang.String TRANSACTIONAL_ID_CONFIG
transactional.id
public static final java.lang.String TRANSACTIONAL_ID_DOC
public ProducerConfig(java.util.Properties props)
props
- An instance of Properties objectpublic ProducerConfig(java.util.Map<java.lang.String,java.lang.Object> props)
props
- A map of properties objectpublic static java.util.Map<java.lang.String,java.lang.Object> addSerializerToConfig(java.util.Map<java.lang.String,java.lang.Object> configs, org.apache.kafka.common.serialization.Serializer<?> keySerializer, org.apache.kafka.common.serialization.Serializer<?> valueSerializer)
configs
- A map of config objectkeySerializer
- A serializer object for keysvalueSerializer
- A serializer object for valuespublic static java.util.Properties addSerializerToConfig(java.util.Properties properties, org.apache.kafka.common.serialization.Serializer<?> keySerializer, org.apache.kafka.common.serialization.Serializer<?> valueSerializer)
properties
- An instance of Properties objectkeySerializer
- A serializer object for keysvalueSerializer
- A serializer object for valuespublic static java.util.Set<java.lang.String> configNames()
public static void main(java.lang.String[] args)