Skip to main content

Module checkpoint

Module checkpoint 

Source
Expand description

KRaft checkpoint selection and retention decisions.

Functionsยง

checkpoint_id_newer
Whether candidate is lexicographically newer than current.
checkpoint_id_retained
Retain a checkpoint whose full (end offset, epoch) id equals either of two given ids, and nothing else: no partial match of either survives.
latest_checkpoint_index
Return the index of the maximum (end offset, epoch) checkpoint id.