Skip to content



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 has to be lower than (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

Time (in millis) to block waiting for input

Default: 100L

Used when:


Default: (undefined)

Back to top