kafka.clients.producer.ProducerConfig |
public static final java.lang.String |
BLOCK_ON_BUFFER_FULL |
"block.on.buffer.full" |
public static final java.lang.String |
BROKER_LIST_CONFIG |
"metadata.broker.list" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
ENABLE_JMX |
"enable.jmx" |
public static final java.lang.String |
LINGER_MS_CONFIG |
"linger.ms" |
public static final java.lang.String |
MAX_PARTITION_SIZE_CONFIG |
"max.partition.bytes" |
public static final java.lang.String |
MAX_REQUEST_SIZE_CONFIG |
"max.request.size" |
public static final java.lang.String |
METADATA_FETCH_TIMEOUT_CONFIG |
"metadata.fetch.timeout.ms" |
public static final java.lang.String |
METADATA_REFRESH_MS_CONFIG |
"topic.metadata.refresh.interval.ms" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
REQUEST_TIMEOUT_CONFIG |
"request.timeout.ms" |
public static final java.lang.String |
REQUIRED_ACKS_CONFIG |
"request.required.acks" |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
TOTAL_BUFFER_MEMORY_CONFIG |
"total.memory.bytes" |