acceptable.recovery.lag |
Medium |
The maximum acceptable lag (number of offsets to catch up) for an instance to be considered caught-up and ready
for the active task. |
10,000 |
application.server |
Low |
A host:port pair pointing to an embedded user defined endpoint that can be used for discovering the locations of
state stores within a single Kafka Streams application. The value of this must be different for each instance
of the application. |
the empty string |
buffered.records.per.partition |
Low |
The maximum number of records to buffer per partition. |
1000 |
cache.max.bytes.buffering |
Medium |
Maximum number of memory bytes to be used for record caches across all threads. |
10485760 bytes |
client.id |
Medium |
An ID string to pass to the server when making requests.
(This setting is passed to the consumer/producer clients used internally by Kafka Streams.) |
the empty string |
commit.interval.ms |
Low |
The frequency with which to save the position (offsets in source topics) of tasks. |
30000 ms (at_least_once ) / 100 ms (exactly_once and exactly_once_beta ) |
default.deserialization.exception.handler |
Medium |
Exception handling class that implements the DeserializationExceptionHandler interface. |
See default.deserialization.exception.handler |
default.production.exception.handler |
Medium |
Exception handling class that implements the ProductionExceptionHandler interface. |
See default.production.exception.handler |
default.key.serde |
Medium |
Default serializer/deserializer class for record keys, implements the Serde interface (see also value.serde). |
Serdes.ByteArray().getClass().getName() |
default.value.serde |
Medium |
Default serializer/deserializer class for record values, implements the Serde interface (see also key.serde). |
Serdes.ByteArray().getClass().getName() |
default.windowed.key.serde.inner |
Medium |
Default inner serializer/deserializer class for record keys, implements the Serde interface.
Only affective if default.key.serde is a windowed serde. |
Serdes.ByteArray().getClass().getName() |
default.windowed.value.serde.inner |
Medium |
Default inner serializer/deserializer class for record values, implements the Serde interface
Only affective if default.value.serde is a windowed serde. |
Serdes.ByteArray().getClass().getName() |
default.timestamp.extractor |
Medium |
Default timestamp extractor class that implements the TimestampExtractor interface. |
See Timestamp Extractor |
max.task.idle.ms |
Medium |
Maximum amount of time a stream task will stay idle when not all of its partition buffers contain records. |
0 milliseconds |
max.warmup.replicas |
Medium |
The maximum number of warmup replicas (extra standbys beyond the configured num.standbys) that can be assigned
at once. |
2 |
metric.reporters |
Low |
A list of classes to use as metrics reporters. |
the empty list |
metrics.num.samples |
Low |
The number of samples maintained to compute metrics. |
2 |
metrics.recording.level |
Low |
The highest recording level for metrics. |
INFO |
metrics.sample.window.ms |
Low |
The window of time a metrics sample is computed over. |
30000 milliseconds |
num.standby.replicas |
Medium |
The number of standby replicas for each task. |
0 |
num.stream.threads |
Medium |
The number of threads to execute stream processing. |
1 |
poll.ms |
Low |
The amount of time in milliseconds to block waiting for input. |
100 milliseconds |
probing.rebalance.interval.ms |
Low |
The maximum time to wait before triggering a rebalance to probe for warmup replicas that have sufficiently
caught up. |
600000 milliseconds (10 minutes) |
processing.guarantee |
Medium |
The processing mode. Can be either at_least_once (default), exactly_once (for EOS version 1), or
exactly_once_beta (for EOS version 2). |
See Processing Guarantee |
replication.factor |
High |
The replication factor for changelog topics and repartition topics created by the application.
If your broker cluster is on version Confluent Platform 5.4.x (Kafka 2.4.x) or newer,
you can set -1 to use the broker default replication factor. |
1 |
retries |
Medium |
The number of retries for broker requests that return a retryable error. |
0 |
retry.backoff.ms |
Medium |
The amount of time in milliseconds, before a request is retried.
This applies if the retries parameter is configured to be greater than 0. |
100 |
rocksdb.config.setter |
Medium |
The RocksDB configuration. |
|
state.cleanup.delay.ms |
Low |
The amount of time in milliseconds to wait before deleting state when a partition has migrated. |
600000 milliseconds |
state.dir |
High |
Directory location for state stores. |
/var/lib/kafka-streams |
topology.optimization |
Low |
Enables/Disables topology optimization. Accepts strings none or all . |
none |
upgrade.from |
Medium |
The version you are upgrading from during a rolling upgrade. |
See Upgrade From |
windowstore.changelog.additional.retention.ms |
Low |
Added to a windows maintainMs to ensure data is not deleted from the log prematurely. Allows for clock drift. |
86400000 milliseconds = 1 day |