Enum CommitFailure 

#[non_exhaustive]
pub enum CommitFailure {
    Rejected(String),
    Deadline(Duration),
    NoThread,
}

Why an offset commit at shutdown was not confirmed; the kind of ShoveError::Commit.

#[non_exhaustive]: match with a wildcard arm.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Rejected(String)

The commit returned an error, carried as text: the coordinator’s answer, or a librdkafka local error, such as a timeout of its own or an unknown partition. An answer from the coordinator says this commit did not land. A local error raised after the request was sent, such as a timeout, does not prove that: librdkafka reports it after its own retries, and the broker may have accepted the commit by then. The next member resumes from whatever position the broker holds.

The text is librdkafka’s rendering of that error: the error code and its description, and nothing else. It never carries a record’s payload, key or headers, nor a personal or account identifier taken from one, so it is safe to log and to return as is.

Deadline(Duration)

The commit had no answer within the time it carries: the shutdown deadline for a final commit, its share of that deadline for a CommitPolicy::PerRecord commit found in flight at the stop, or the time waited when the commit thread ended without reporting. The result is unknown: the detached commit thread may still land it after the consumer has returned.

NoThread

No thread could be spawned to run the commit, so this commit was never made and the consumer’s close moved off the runtime by itself.

Trait Implementations

impl Clone for CommitFailure

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommitFailure

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

Formats the value using the given formatter.

impl Display for CommitFailure

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

Formats the value using the given formatter.

impl Eq for CommitFailure

impl Error for CommitFailure

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl PartialEq for CommitFailure

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for CommitFailure