pub fn position_record(topic: &str, partition: i32, next: i64) -> Vec<u8> ⓘExpand description
The position record of a single-partition source (partition is its task index): the one shape
the checkpoint reads a source’s positions from — topic keys the restore’s lookup, in maps a
partition to the next offset. Every in-process source writes its barrier record with this.