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 |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
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 |
HEARTBEAT_INTERVAL_MS_CONFIG |
"heartbeat.interval.ms" |
public static final java.lang.String |
KEY_DESERIALIZER_CLASS_CONFIG |
"key.deserializer" |
public static final java.lang.String |
KEY_DESERIALIZER_CLASS_DOC |
"Deserializer class for key that implements the <code>Deserializer</code> interface." |
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 |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.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 |
STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG |
"streams.consumer.buffer.memory" |
public static final java.lang.String |
STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG |
"streams.consumer.default.stream" |
public static final java.lang.String |
STREAMS_HARDMOUNT_CONFIG |
"fs.mapr.hardmount" |
public static final java.lang.String |
STREAMS_RECORD_STRIP_STREAMPATH_CONFIG |
"streams.record.strip.streampath" |
public static final java.lang.String |
STREAMS_RPC_TIMEOUT_CONFIG |
"fs.mapr.rpc.timeout" |
public static final java.lang.String |
STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG |
"streams.zerooffset.record.on.eof" |
public static final java.lang.String |
VALUE_DESERIALIZER_CLASS_CONFIG |
"value.deserializer" |
public static final java.lang.String |
VALUE_DESERIALIZER_CLASS_DOC |
"Deserializer class for value that implements the <code>Deserializer</code> interface." |
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 |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final java.lang.String |
KEY_SERIALIZER_CLASS_CONFIG |
"key.serializer" |
public static final java.lang.String |
KEY_SERIALIZER_CLASS_DOC |
"Serializer class for key that implements the <code>Serializer</code> interface." |
public static final java.lang.String |
LINGER_MS_CONFIG |
"linger.ms" |
public static final java.lang.String |
MAX_BLOCK_MS_CONFIG |
"max.block.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 |
PARTITIONER_CLASS_CONFIG |
"partitioner.class" |
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 |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.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 |
STREAMS_BUFFER_TIME_CONFIG |
"streams.buffer.max.time.ms" |
public static final java.lang.String |
STREAMS_HARDMOUNT_CONFIG |
"fs.mapr.hardmount" |
public static final java.lang.String |
STREAMS_PARALLEL_FLUSHERS_PER_PARTITION_CONFIG |
"streams.parallel.flushers.per.partition" |
public static final java.lang.String |
STREAMS_PARTITIONER_CLASS_CONFIG |
"streams.partitioner.class" |
public static final java.lang.String |
STREAMS_PRODUCER_DEFAULT_STREAM_CONFIG |
"streams.producer.default.stream" |
public static final java.lang.String |
STREAMS_RPC_TIMEOUT_CONFIG |
"fs.mapr.rpc.timeout" |
public static final java.lang.String |
TIMEOUT_CONFIG |
"timeout.ms" |
public static final java.lang.String |
VALUE_SERIALIZER_CLASS_CONFIG |
"value.serializer" |
public static final java.lang.String |
VALUE_SERIALIZER_CLASS_DOC |
"Serializer class for value that implements the <code>Serializer</code> interface." |