Struct Fetched 

pub struct Fetched {
    pub records: Vec<Record>,
    pub next_offset: i64,
}

What a fetch yielded, after filtering.

Fields

records: Vec<Record>

Records the caller may have.

next_offset: i64

Where the next fetch should start.

Advances past filtered records too, which is not a detail: a fetch whose every record was aborted must still make progress, or the consumer re-requests the same offset forever and stalls on a partition that is perfectly healthy.

Trait Implementations

impl Debug for Fetched

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Fetched

fn default() -> Fetched

Returns the “default value” for a type.