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 createdInternalTopologyBuilder
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 aStateConsumer
)StoreChangelogReader
is createdStreamThread
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 createdGlobalStreamThread
is requested to initializeStoreChangelogReader
is createdStreamThread
is created
task.timeout.ms¶
upgrade.from¶
Default: (undefined)