Skip to main content

parse_offset_index

Function parse_offset_index 

Source
pub fn parse_offset_index(
    bytes: &[u8],
) -> Result<&[OffsetIndexEntry], RemoteStorageError>
Expand description

Borrows Kafka’s OffsetIndex on-disk format as a zero-copy &[OffsetIndexEntry].

Each entry is 8 bytes: rel u32 BE, then pos u32 BE. It ignores trailing bytes that do not complete an 8-byte entry. The result borrows from bytes.

§Errors

Returns RemoteStorageError::Io when the object store returned bytes that do not form an entry array.