Enum rdkafka::consumer::CommitMode

pub enum CommitMode {
    Sync = 0,
    Async = 1,
}

Specifies whether a commit should be performed synchronously or asynchronously.

A commit is performed via Consumer::commit or one of its variants.

Regardless of the CommitMode, the commit APIs enqueue the commit request in a local work queue. A separate worker thread picks up this commit request and forwards it to the Kafka broker over the network.

The difference between CommitMode::Sync and CommitMode::Async is in whether the caller waits for the Kafka broker to respond that it finished handling the commit request.

Note that the commit APIs are not async in the Rust sense due to the lack of a callback-based interface exposed by librdkafka. See librdkafka#3212.

Variants

Sync = 0

In Sync mode, the caller blocks until the Kafka broker finishes processing the commit request.

Async = 1

In Async mode, the caller enqueues the commit request in a local work queue and returns immediately.

Trait Implementations

impl Clone for CommitMode

fn clone(&self) -> CommitMode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CommitMode

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

Formats the value using the given formatter.

impl Copy for CommitMode