Skip to content

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:

task.timeout.ms

upgrade.from

Default: (undefined)

Back to top