public static final java.lang.String |
ADMIN_CLIENT_PREFIX |
"admin." |
public static final java.lang.String |
APPLICATION_ID_CONFIG |
"application.id" |
public static final java.lang.String |
APPLICATION_SERVER_CONFIG |
"application.server" |
public static final java.lang.String |
AT_LEAST_ONCE |
"at_least_once" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
BUFFERED_RECORDS_PER_PARTITION_CONFIG |
"buffered.records.per.partition" |
public static final java.lang.String |
CACHE_MAX_BYTES_BUFFERING_CONFIG |
"cache.max.bytes.buffering" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
COMMIT_INTERVAL_MS_CONFIG |
"commit.interval.ms" |
public static final java.lang.String |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final java.lang.String |
CONSUMER_PREFIX |
"consumer." |
public static final java.lang.String |
DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG |
"default.deserialization.exception.handler" |
public static final java.lang.String |
DEFAULT_KEY_SERDE_CLASS_CONFIG |
"default.key.serde" |
public static final java.lang.String |
DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG |
"default.production.exception.handler" |
public static final java.lang.String |
DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG |
"default.timestamp.extractor" |
public static final java.lang.String |
DEFAULT_VALUE_SERDE_CLASS_CONFIG |
"default.value.serde" |
public static final java.lang.String |
EXACTLY_ONCE |
"exactly_once" |
public static final java.lang.String |
KEY_SERDE_CLASS_CONFIG |
"key.serde" |
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_RECORDING_LEVEL_CONFIG |
"metrics.recording.level" |
public static final java.lang.String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
"metrics.sample.window.ms" |
public static final java.lang.String |
NUM_STANDBY_REPLICAS_CONFIG |
"num.standby.replicas" |
public static final java.lang.String |
NUM_STREAM_THREADS_CONFIG |
"num.stream.threads" |
public static final java.lang.String |
PARTITION_GROUPER_CLASS_CONFIG |
"partition.grouper" |
public static final java.lang.String |
POLL_MS_CONFIG |
"poll.ms" |
public static final java.lang.String |
PROCESSING_GUARANTEE_CONFIG |
"processing.guarantee" |
public static final java.lang.String |
PRODUCER_PREFIX |
"producer." |
public static final java.lang.String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final java.lang.String |
RECONNECT_BACKOFF_MAX_MS_CONFIG |
"reconnect.backoff.max.ms" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
REPLICATION_FACTOR_CONFIG |
"replication.factor" |
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 |
ROCKSDB_CONFIG_SETTER_CLASS_CONFIG |
"rocksdb.config.setter" |
public static final java.lang.String |
SECURITY_PROTOCOL_CONFIG |
"security.protocol" |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
STATE_CLEANUP_DELAY_MS_CONFIG |
"state.cleanup.delay.ms" |
public static final java.lang.String |
STATE_DIR_CONFIG |
"state.dir" |
public static final java.lang.String |
TIMESTAMP_EXTRACTOR_CLASS_CONFIG |
"timestamp.extractor" |
public static final java.lang.String |
TOPIC_PREFIX |
"topic." |
public static final java.lang.String |
UPGRADE_FROM_0100 |
"0.10.0" |
public static final java.lang.String |
UPGRADE_FROM_CONFIG |
"upgrade.from" |
public static final java.lang.String |
UPGRADE_FROM_DOC |
"Allows upgrading from version 0.10.0 to version 0.10.1 (or newer) in a backward compatible way. Default is null. Accepted values are \"0.10.0\" (for upgrading from 0.10.0.x)." |
public static final java.lang.String |
VALUE_SERDE_CLASS_CONFIG |
"value.serde" |
public static final java.lang.String |
WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG |
"windowstore.changelog.additional.retention.ms" |
public static final java.lang.String |
ZOOKEEPER_CONNECT_CONFIG |
"zookeeper.connect" |