Skip to content

StreamsConfig

application.id

cache.max.bytes.buffering

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

poll.ms

Time (in millis) to block waiting for input

Default: 100L

Used when:

task.timeout.ms

upgrade.from

Default: (undefined)

Back to top