Application ID that is the required identifier of a Kafka Streams stream processing application

Default: (empty)

application.id must be unique within the Kafka cluster as it is used as a namespace for the default client-id prefix, the group-id for membership management, and the prefix for internal topics (that Kafka Streams creates internally).

application.id is used as a Kafka consumer group ID (that you can check out using kafka-consumer-groups.sh script)

Use StreamsConfig.APPLICATION_ID_CONFIG to reference the property.

Client ID of internal consumer, producer and restore-consumer, with pattern <client.id>-StreamThread-<threadSequenceNumber>-<consumer,producer,restore-consumer>

Default: (empty)

Used when:

Use StreamsConfig.CLIENT_ID_CONFIG to reference the property.

Flush interval or commit interval (in millis), i.e. how often StreamThread attempts to commit the position of processors and flush state stores

Default:

Must be at least 0L

Use StreamsConfig.COMMIT_INTERVAL_MS_CONFIG to reference the property.

Inner serde class that implements the org.apache.kafka.common.serialization.Serde interface

Default: (empty)

Use StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS to reference the property.

Inner serde class that implements the org.apache.kafka.common.serialization.Serde interface

Default: (empty)

Use StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS to reference the property.

Default timestamp extractor class that implements the org.apache.kafka.streams.processor.TimestampExtractor interface.

Default: FailOnInvalidTimestamp

How long a stream task will stay idle when not all of its partition buffers contain records, to avoid potential out-of-order record processing across multiple input streams.

Default: 0L

Use StreamsConfig.MAX_TASK_IDLE_MS_CONFIG to reference the property.

The highest recording level for metrics

Default: INFO

Possible values are:

Use StreamsConfig.METRICS_RECORDING_LEVEL_CONFIG to reference the property.

The number of standby replicas per processing task

Default: 0

Use StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG to reference the property.

The number of stream processor threads (that KafkaStreams uses for stream processing)

Default: 1

Use StreamsConfig.NUM_STREAM_THREADS_CONFIG to reference the property.

Polling interval (in milliseconds), i.e. the time spent waiting in Consumer.poll (unless data is available in the buffer already). If 0, returns immediately with any records that are available currently in the buffer, else returns empty. Must not be negative.

Default: 100

Used when:

Use StreamsConfig.POLL_MS_CONFIG to reference the property.

Processing guarantee (aka Exactly-Once Support or EOS support)

Default: at_least_once

Possible values are:

Use StreamsConfig.PROCESSING_GUARANTEE_CONFIG to reference the property.

The replication factor for changelog topics and repartition topics created by a stream processing application

Default: 1

Use StreamsConfig.REPLICATION_FACTOR_CONFIG to reference the property.

The amount of time (in milliseconds) to wait before deleting state when a partition has migrated. Only state directories that have not been modified for at least state.cleanup.delay.ms will be removed.

Default: 10 * 60 * 1000 (i.e. 10 mins)

Used exclusively when KafkaStreams is created

Use StreamsConfig.STATE_CLEANUP_DELAY_MS_CONFIG to reference the property.

Path to the base directory for a state storage

Default: /tmp/kafka-streams

Used when StateDirectory is created

Use StreamsConfig.STATE_DIR_CONFIG to reference the property.

Added to a Window maintainMs to ensure data is not deleted from the log prematurely. Allows for clock drift.

Default: 24 * 60 * 60 * 1000L (i.e. 1 day)