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_DIR_ACES_CONFIG	"streams.appdir.aces"
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	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	STREAMS_DEFAULT_STREAM_CONFIG	"streams.default.stream"
public static final java.lang.String	STREAMS_INTERNAL_STREAM_COMMON_FOLDER	"/apps/kafka-streams/"
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	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__"

org.apache.kafka.streams.kstream.internals.WindowingDefaults

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_RETENTION_MS	86400000L

org.apache.kafka.streams.processor.internals.AbstractProcessorContext

Modifier and Type	Constant Field	Value
public static final java.lang.String	NONEXIST_TOPIC	"__null_topic__"

org.apache.kafka.streams.processor.internals.RecordQueue

Modifier and Type	Constant Field	Value
public static final long	UNKNOWN	-1L

org.apache.kafka.streams.processor.internals.Task

Modifier and Type	Constant Field	Value
public static final long	LATEST_OFFSET	-2L

org.apache.kafka.streams.processor.internals.assignment.StreamsAssignmentProtocolVersions

Modifier and Type	Constant Field	Value
public static final int	EARLIEST_PROBEABLE_VERSION	3
public static final int	LATEST_SUPPORTED_VERSION	8
public static final int	UNKNOWN	-1

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo

Modifier and Type	Constant Field	Value
public static final long	UNKNOWN_OFFSET_SUM	-3L

org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl

Modifier and Type	Constant Field	Value
public static final java.lang.String	AVG_LATENCY_DESCRIPTION	"The average latency of "
public static final java.lang.String	AVG_SUFFIX	"-avg"
public static final java.lang.String	BUFFER_ID_TAG	"buffer-id"
public static final java.lang.String	BUFFER_LEVEL_GROUP_0100_TO_24	"stream-buffer-metrics"
public static final java.lang.String	CACHE_LEVEL_GROUP	"stream-record-cache-metrics"
public static final java.lang.String	CLIENT_ID_TAG	"client-id"
public static final java.lang.String	CLIENT_LEVEL_GROUP	"stream-metrics"
public static final java.lang.String	GROUP_PREFIX	"stream-"
public static final java.lang.String	GROUP_PREFIX_WO_DELIMITER	"stream"
public static final java.lang.String	GROUP_SUFFIX	"-metrics"
public static final java.lang.String	LATENCY_SUFFIX	"-latency"
public static final java.lang.String	MAX_LATENCY_DESCRIPTION	"The maximum latency of "
public static final java.lang.String	MAX_SUFFIX	"-max"
public static final java.lang.String	MIN_SUFFIX	"-min"
public static final java.lang.String	OPERATIONS	" operations"
public static final java.lang.String	P90_SUFFIX	"-p90"
public static final java.lang.String	P99_SUFFIX	"-p99"
public static final java.lang.String	PROCESSOR_NODE_ID_TAG	"processor-node-id"
public static final java.lang.String	PROCESSOR_NODE_LEVEL_GROUP	"stream-processor-node-metrics"
public static final java.lang.String	RATE_DESCRIPTION	"The average per-second number of "
public static final java.lang.String	RATE_DESCRIPTION_PREFIX	"The average number of "
public static final java.lang.String	RATE_DESCRIPTION_SUFFIX	" per second"
public static final java.lang.String	RATE_SUFFIX	"-rate"
public static final java.lang.String	RATIO_SUFFIX	"-ratio"
public static final java.lang.String	RECORD_CACHE_ID_TAG	"record-cache-id"
public static final java.lang.String	RECORDS_SUFFIX	"-records"
public static final java.lang.String	ROLLUP_VALUE	"all"
public static final java.lang.String	STATE_STORE_LEVEL_GROUP	"stream-state-metrics"
public static final java.lang.String	STORE_ID_TAG	"state-id"
public static final java.lang.String	TASK_ID_TAG	"task-id"
public static final java.lang.String	TASK_LEVEL_GROUP	"stream-task-metrics"
public static final java.lang.String	THREAD_ID_TAG	"thread-id"
public static final java.lang.String	THREAD_ID_TAG_0100_TO_24	"client-id"
public static final java.lang.String	THREAD_LEVEL_GROUP	"stream-thread-metrics"
public static final java.lang.String	THREAD_LEVEL_GROUP_0100_TO_24	"stream-metrics"
public static final java.lang.String	TOTAL_DESCRIPTION	"The total number of "
public static final java.lang.String	TOTAL_SUFFIX	"-total"

org.apache.kafka.streams.state.internals.Murmur3

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_SEED	104729
public static final long	NULL_HASHCODE	2862933555777941757L

org.apache.kafka.streams.state.internals.OffsetCheckpoint

Modifier and Type	Constant Field	Value
public static final long	OFFSET_UNKNOWN	-4L