Page History

...

We will add the above config parameter to StreamsConfig. During `StreamTask#commitStreamTask#commit()`, `StandbyTask#commitStandbyTask#commit()`, and `GlobalUpdateStateTask#flushStateGlobalUpdateStateTask#flushState()` we  we will check if the checkpoint interval has elapsed and write the checkpoint file. If the checkpoint interval hasn't elapsed then nothing is written. Checkpointing is disabled if the checkpoint interval is set to a value <=0.

As this is done only on commit, the minimum checkpoint interval will be the value of commit.interval.ms. In effect the actual checkpoint interval will be a multiple of the commit interval. This is required as we explicitly flush the state stores on commit and we need to ensure that any offsets we checkpoint have been both flushed to disk and written to any change-logs that exist.

...