Skip to main content

producer_snapshot_latest_index

Function producer_snapshot_latest_index 

Source
pub fn producer_snapshot_latest_index(
    offsets: &[i64],
    range: ProducerReloadRange,
) -> Option<usize>
Expand description

Return the index of the newest snapshot a reload keeps, as Kafka’s loadFromSnapshot loads latestSnapshotFile() after truncateAndReload deleted every snapshot outside (log_start, log_end].

Input order is irrelevant.