Enum fluvio::consumer::OffsetManagementStrategy

pub enum OffsetManagementStrategy {
    None,
    Manual,
    Auto,
}

Variants

None

Offsets are not saved

Manual

All operations must be invoked explicitly.

Auto

Before yielding a new record to the caller, the previous record is committed and flushed if the configured interval is passed. Additionally, the commit and the flush are triggered when the stream object gets dropped.

Trait Implementations

impl Clone for OffsetManagementStrategy

fn clone(&self) -> OffsetManagementStrategy

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OffsetManagementStrategy

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

Formats the value using the given formatter.

impl Default for OffsetManagementStrategy

fn default() -> OffsetManagementStrategy

Returns the “default value” for a type.

impl Copy for OffsetManagementStrategy