StreamsConfig¶

application.id¶

application.server¶

A host:port endpoint address of the KafkaStreams instance

buffered.records.per.partition¶

Maximum number of records to buffer per partition (that StreamTask uses for pausing and resuming record fetching)

Default: 1000

built.in.metrics.version¶

cache.max.bytes.buffering¶

Maximum number of memory bytes for buffering across all threads (that KafkaStreams uses to indirectly create ThreadCaches).

Default: 10MB (10 * 1024 * 1024L)

Must be at least 0

Used when:

• KafkaStreams is created
• InternalTopologyBuilder is requested to rewriteTopology (and disable caching for local and global state stores)
• TopologyTestDriver is created

client.id¶

See Apache Kafka

commit.interval.ms¶

How often to save (commit and flush) the position of a processor

Default: 30000L (or 100L for processing.guarantee being exactly_once_v2 or deprecated exactly_once)

Must be at least 0

commit.interval.ms has to be lower than transaction.timeout.ms (or ongoing transaction always time out due to inactivity caused by long commit interval)

Used when:

• GlobalStreamThread is requested to initialize (and create a StateConsumer)
• StoreChangelogReader is created
• StreamThread is created

default.deserialization.exception.handler¶

The default DeserializationExceptionHandler

Default: LogAndFailExceptionHandler

default.timestamp.extractor¶

The default TimestampExtractor

Default: FailOnInvalidTimestamp

max.task.idle.ms¶

metrics.num.samples¶

(Re)Defined in StreamsConfig as CommonClientConfigs.METRICS_NUM_SAMPLES_CONFIG (Apache Kafka)

metrics.recording.level¶

(Re)Defined in StreamsConfig as CommonClientConfigs.METRICS_RECORDING_LEVEL_CONFIG (Apache Kafka)

metric.reporters¶

(Re)Defined in StreamsConfig as CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG (Apache Kafka)

metrics.sample.window.ms¶

(Re)Defined in StreamsConfig as CommonClientConfigs.METRICS_SAMPLE_WINDOW_MS_CONFIG (Apache Kafka)

poll.ms¶

Time (in millis) to block waiting for input

Default: 100L

Used when:

• GlobalStateManagerImpl is created
• GlobalStreamThread is requested to initialize
• StoreChangelogReader is created
• StreamThread is created

task.timeout.ms¶

upgrade.from¶

Default: (undefined)