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	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	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 java.lang.String	EXACTLY_ONCE	"exactly_once"
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	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	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	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_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	TASK_MANAGER_FOR_PARTITION_ASSIGNOR	"__task.manager.instance__"

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.assignment.AssignmentInfo

Modifier and Type	Constant Field	Value
public static final int	LATEST_SUPPORTED_VERSION	4

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

Modifier and Type	Constant Field	Value
public static final int	LATEST_SUPPORTED_VERSION	4

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	PROCESSOR_NODE_ID_TAG	"processor-node-id"
public static final java.lang.String	PROCESSOR_NODE_METRICS_GROUP	"stream-processor-node-metrics"