public static final String |
ACCEPTABLE_RECOVERY_LAG_CONFIG |
"acceptable.recovery.lag" |
public static final String |
ADMIN_CLIENT_PREFIX |
"admin." |
public static final String |
APPLICATION_ID_CONFIG |
"application.id" |
public static final String |
APPLICATION_SERVER_CONFIG |
"application.server" |
public static final String |
AT_LEAST_ONCE |
"at_least_once" |
public static final String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final String |
BUFFERED_RECORDS_PER_PARTITION_CONFIG |
"buffered.records.per.partition" |
public static final String |
BUILT_IN_METRICS_VERSION_CONFIG |
"built.in.metrics.version" |
public static final String |
CACHE_MAX_BYTES_BUFFERING_CONFIG |
"cache.max.bytes.buffering" |
public static final String |
CLIENT_ID_CONFIG |
"client.id" |
public static final String |
COMMIT_INTERVAL_MS_CONFIG |
"commit.interval.ms" |
public static final String |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final String |
CONSUMER_PREFIX |
"consumer." |
public static final String |
DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG |
"default.deserialization.exception.handler" |
public static final String |
DEFAULT_KEY_SERDE_CLASS_CONFIG |
"default.key.serde" |
public static final String |
DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG |
"default.production.exception.handler" |
public static final String |
DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG |
"default.timestamp.extractor" |
public static final String |
DEFAULT_VALUE_SERDE_CLASS_CONFIG |
"default.value.serde" |
public static final String |
DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS |
"default.windowed.key.serde.inner" |
public static final String |
DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS |
"default.windowed.value.serde.inner" |
public static final int |
DUMMY_THREAD_INDEX |
1 |
public static final String |
EXACTLY_ONCE |
"exactly_once" |
public static final String |
EXACTLY_ONCE_BETA |
"exactly_once_beta" |
public static final String |
EXACTLY_ONCE_V2 |
"exactly_once_v2" |
public static final String |
GLOBAL_CONSUMER_PREFIX |
"global.consumer." |
public static final String |
MAIN_CONSUMER_PREFIX |
"main.consumer." |
public static final String |
MAX_TASK_IDLE_MS_CONFIG |
"max.task.idle.ms" |
public static final long |
MAX_TASK_IDLE_MS_DISABLED |
-1L |
public static final String |
MAX_WARMUP_REPLICAS_CONFIG |
"max.warmup.replicas" |
public static final String |
METADATA_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final String |
METRIC_REPORTER_CLASSES_CONFIG |
"metric.reporters" |
public static final String |
METRICS_LATEST |
"latest" |
public static final String |
METRICS_NUM_SAMPLES_CONFIG |
"metrics.num.samples" |
public static final String |
METRICS_RECORDING_LEVEL_CONFIG |
"metrics.recording.level" |
public static final String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
"metrics.sample.window.ms" |
public static final String |
NO_OPTIMIZATION |
"none" |
public static final String |
NUM_STANDBY_REPLICAS_CONFIG |
"num.standby.replicas" |
public static final String |
NUM_STREAM_THREADS_CONFIG |
"num.stream.threads" |
public static final String |
OPTIMIZE |
"all" |
public static final String |
POLL_MS_CONFIG |
"poll.ms" |
public static final String |
PROBING_REBALANCE_INTERVAL_MS_CONFIG |
"probing.rebalance.interval.ms" |
public static final String |
PROCESSING_GUARANTEE_CONFIG |
"processing.guarantee" |
public static final String |
PRODUCER_PREFIX |
"producer." |
public static final String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final String |
RECONNECT_BACKOFF_MAX_MS_CONFIG |
"reconnect.backoff.max.ms" |
public static final String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final String |
REPLICATION_FACTOR_CONFIG |
"replication.factor" |
public static final String |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.ms" |
public static final String |
RESTORE_CONSUMER_PREFIX |
"restore.consumer." |
public static final String |
RETRIES_CONFIG |
"retries" |
public static final String |
RETRY_BACKOFF_MS_CONFIG |
"retry.backoff.ms" |
public static final String |
ROCKSDB_CONFIG_SETTER_CLASS_CONFIG |
"rocksdb.config.setter" |
public static final String |
SECURITY_PROTOCOL_CONFIG |
"security.protocol" |
public static final String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final String |
STATE_CLEANUP_DELAY_MS_CONFIG |
"state.cleanup.delay.ms" |
public static final String |
STATE_DIR_CONFIG |
"state.dir" |
public static final String |
TASK_TIMEOUT_MS_CONFIG |
"task.timeout.ms" |
public static final String |
TASK_TIMEOUT_MS_DOC |
"The maximum amount of time in milliseconds a task might stall due to internal errors and retries until an error is raised. For a timeout of 0ms, a task would raise an error for the first internal error. For any timeout larger than 0ms, a task will retry at least once before an error is raised." |
public static final String |
TOPIC_PREFIX |
"topic." |
public static final String |
TOPOLOGY_OPTIMIZATION |
"topology.optimization" |
public static final String |
TOPOLOGY_OPTIMIZATION_CONFIG |
"topology.optimization" |
public static final String |
UPGRADE_FROM_0100 |
"0.10.0" |
public static final String |
UPGRADE_FROM_0101 |
"0.10.1" |
public static final String |
UPGRADE_FROM_0102 |
"0.10.2" |
public static final String |
UPGRADE_FROM_0110 |
"0.11.0" |
public static final String |
UPGRADE_FROM_10 |
"1.0" |
public static final String |
UPGRADE_FROM_11 |
"1.1" |
public static final String |
UPGRADE_FROM_20 |
"2.0" |
public static final String |
UPGRADE_FROM_21 |
"2.1" |
public static final String |
UPGRADE_FROM_22 |
"2.2" |
public static final String |
UPGRADE_FROM_23 |
"2.3" |
public static final String |
UPGRADE_FROM_CONFIG |
"upgrade.from" |
public static final String |
WINDOW_SIZE_MS_CONFIG |
"window.size.ms" |
public static final String |
WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG |
"windowstore.changelog.additional.retention.ms" |
public static final String |
WINDOWED_INNER_CLASS_SERDE |
"windowed.inner.class.serde" |