Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
AUTO_COMMIT_INTERVAL_MS_CONFIG |
"auto.commit.interval.ms" |
public static final java.lang.String |
AUTO_OFFSET_RESET_CONFIG |
"auto.offset.reset" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
CHECK_CRCS_CONFIG |
"check.crcs" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
CONSUMER_REBALANCE_CALLBACK_CLASS_CONFIG |
"rebalance.callback.class" |
public static final java.lang.String |
ENABLE_AUTO_COMMIT_CONFIG |
"enable.auto.commit" |
public static final java.lang.String |
FETCH_MAX_WAIT_MS_CONFIG |
"fetch.max.wait.ms" |
public static final java.lang.String |
FETCH_MIN_BYTES_CONFIG |
"fetch.min.bytes" |
public static final java.lang.String |
GROUP_ID_CONFIG |
"group.id" |
public static final java.lang.String |
KEY_DESERIALIZER_CLASS_CONFIG |
"key.deserializer" |
public static final java.lang.String |
MAX_PARTITION_FETCH_BYTES_CONFIG |
"max.partition.fetch.bytes" |
public static final java.lang.String |
METADATA_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final java.lang.String |
METRIC_REPORTER_CLASSES_CONFIG |
"metric.reporters" |
public static final java.lang.String |
METRICS_NUM_SAMPLES_CONFIG |
"metrics.num.samples" |
public static final java.lang.String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
"metrics.sample.window.ms" |
public static final java.lang.String |
PARTITION_ASSIGNMENT_STRATEGY_CONFIG |
"partition.assignment.strategy" |
public static final java.lang.String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
RETRY_BACKOFF_MS_CONFIG |
"retry.backoff.ms" |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
SESSION_TIMEOUT_MS_CONFIG |
"session.timeout.ms" |
public static final java.lang.String |
VALUE_DESERIALIZER_CLASS_CONFIG |
"value.deserializer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ACKS_CONFIG |
"acks" |
public static final java.lang.String |
BATCH_SIZE_CONFIG |
"batch.size" |
public static final java.lang.String |
BLOCK_ON_BUFFER_FULL_CONFIG |
"block.on.buffer.full" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
BUFFER_MEMORY_CONFIG |
"buffer.memory" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
COMPRESSION_TYPE_CONFIG |
"compression.type" |
public static final java.lang.String |
KEY_SERIALIZER_CLASS_CONFIG |
"key.serializer" |
public static final java.lang.String |
LINGER_MS_CONFIG |
"linger.ms" |
public static final java.lang.String |
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION |
"max.in.flight.requests.per.connection" |
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_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final java.lang.String |
METRIC_REPORTER_CLASSES_CONFIG |
"metric.reporters" |
public static final java.lang.String |
METRICS_NUM_SAMPLES_CONFIG |
"metrics.num.samples" |
public static final java.lang.String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
"metrics.sample.window.ms" |
public static final java.lang.String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
RETRIES_CONFIG |
"retries" |
public static final java.lang.String |
RETRY_BACKOFF_MS_CONFIG |
"retry.backoff.ms" |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
TIMEOUT_CONFIG |
"timeout.ms" |
public static final java.lang.String |
VALUE_SERIALIZER_CLASS_CONFIG |
"value.serializer" |