Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.kafka.streams.StreamsConfig

Modifier and Type	Constant Field	Value
public static final java.lang.String	ACCEPTABLE_RECOVERY_LAG_CONFIG	"acceptable.recovery.lag"
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	BUILT_IN_METRICS_VERSION_CONFIG	"built.in.metrics.version"
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	DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS	"default.windowed.key.serde.inner"
public static final java.lang.String	DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS	"default.windowed.value.serde.inner"
public static final int	DUMMY_THREAD_INDEX	1
public static final java.lang.String	EXACTLY_ONCE	"exactly_once"
public static final java.lang.String	EXACTLY_ONCE_BETA	"exactly_once_beta"
public static final java.lang.String	GLOBAL_CONSUMER_PREFIX	"global.consumer."
public static final java.lang.String	MAIN_CONSUMER_PREFIX	"main.consumer."
public static final java.lang.String	MAX_TASK_IDLE_MS_CONFIG	"max.task.idle.ms"
public static final java.lang.String	MAX_WARMUP_REPLICAS_CONFIG	"max.warmup.replicas"
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_0100_TO_24	"0.10.0-2.4"
public static final java.lang.String	METRICS_LATEST	"latest"
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	NO_OPTIMIZATION	"none"
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	OPTIMIZE	"all"
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	PROBING_REBALANCE_INTERVAL_MS_CONFIG	"probing.rebalance.interval.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	RESTORE_CONSUMER_PREFIX	"restore.consumer."
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	TASK_TIMEOUT_MS_CONFIG	"task.timeout.ms"
public static final java.lang.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 java.lang.String	TOPIC_PREFIX	"topic."
public static final java.lang.String	TOPOLOGY_OPTIMIZATION	"topology.optimization"
public static final java.lang.String	TOPOLOGY_OPTIMIZATION_CONFIG	"topology.optimization"
public static final java.lang.String	UPGRADE_FROM_0100	"0.10.0"
public static final java.lang.String	UPGRADE_FROM_0101	"0.10.1"
public static final java.lang.String	UPGRADE_FROM_0102	"0.10.2"
public static final java.lang.String	UPGRADE_FROM_0110	"0.11.0"
public static final java.lang.String	UPGRADE_FROM_10	"1.0"
public static final java.lang.String	UPGRADE_FROM_11	"1.1"
public static final java.lang.String	UPGRADE_FROM_20	"2.0"
public static final java.lang.String	UPGRADE_FROM_21	"2.1"
public static final java.lang.String	UPGRADE_FROM_22	"2.2"
public static final java.lang.String	UPGRADE_FROM_23	"2.3"
public static final java.lang.String	UPGRADE_FROM_CONFIG	"upgrade.from"
public static final java.lang.String	WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG	"windowstore.changelog.additional.retention.ms"

org.apache.kafka.streams.StreamsConfig.InternalConfig

Modifier and Type	Constant Field	Value
public static final java.lang.String	ASSIGNMENT_ERROR_CODE	"__assignment.error.code__"
public static final java.lang.String	ASSIGNMENT_LISTENER	"__assignment.listener__"
public static final java.lang.String	INTERNAL_TASK_ASSIGNOR_CLASS	"internal.task.assignor.class"
public static final java.lang.String	NEXT_SCHEDULED_REBALANCE_MS	"__next.probing.rebalance.ms__"
public static final java.lang.String	STREAMS_ADMIN_CLIENT	"__streams.admin.client.instance__"
public static final java.lang.String	STREAMS_METADATA_STATE_FOR_PARTITION_ASSIGNOR	"__streams.metadata.state.instance__"
public static final java.lang.String	TASK_MANAGER_FOR_PARTITION_ASSIGNOR	"__task.manager.instance__"
public static final java.lang.String	TIME	"__time__"