Enum CommitStrategy 

pub enum CommitStrategy {
    AfterProcess,
    AfterPoll,
    Manual,
}

When to commit offsets.

Variants

AfterProcess

Commit after each message is processed (at-least-once, slow).

AfterPoll

Commit after each batch poll (at-least-once, faster).

Manual

Manual commit (caller controls).

Trait Implementations

impl Clone for CommitStrategy

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for CommitStrategy

impl Debug for CommitStrategy

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

Formats the value using the given formatter.

impl Eq for CommitStrategy

impl PartialEq for CommitStrategy

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CommitStrategy