Page History

...

On close of the GlobalKTable, we will write out a checkpoint file to the global table’s state directory,  containing located under the global sub-directory of StreamsConfig.STATE_DIR_CONFIG, containing the current offset for each partition in the GlobalKTable. The checkpoint file will be used to recover during restarts. On restart we will first check for the existence of the checkpoint file, if it exists we will read in the current offsets for each partition and seek to those offsets and start consuming. In the event the checkpoint file doesn’t exist, we will restore from the earliest offset.

...