Enum CommitStrategy 

pub enum CommitStrategy {
    Auto,
    Periodic(usize),
    Manual,
}

Strategy for committing offsets.

Variants

Auto

Automatically commit after each item is processed.

Periodic(usize)

Commit periodically based on count.

Manual

Only commit when explicitly requested.

Trait Implementations

impl Clone for CommitStrategy

fn clone(&self) -> CommitStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommitStrategy

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

Formats the value using the given formatter.

impl Default for CommitStrategy

fn default() -> CommitStrategy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CommitStrategy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CommitStrategy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for CommitStrategy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for CommitStrategy

impl Eq for CommitStrategy

impl StructuralPartialEq for CommitStrategy