Struct FailedCommit 

#[non_exhaustive]
pub struct FailedCommit {
    pub topic: String,
    pub offsets: Vec<(i32, i64)>,
    pub kind: CommitFailure,
}

An offset commit at shutdown that was not confirmed, the final commit or under CommitPolicy::PerRecord the commit in flight when the stop landed: what the commit carried and why it was not confirmed. The payload of ShoveError::Commit.

#[non_exhaustive]: read the fields, and match with .., so a field can be added later.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

topic: String

The topic the member consumed.

offsets: Vec<(i32, i64)>

The offsets the consumer tried to commit, per partition: one (partition, offset) pair per partition the member held, the offset exclusive as Kafka commits it. Never empty: a member with nothing to commit has no commit to fail.

kind: CommitFailure

How the commit failed: the error it returned, no answer within the deadline, or no thread to run it on.

Trait Implementations

impl Clone for FailedCommit

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 FailedCommit

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

Formats the value using the given formatter.

impl Display for FailedCommit

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

Formats the value using the given formatter.

impl Eq for FailedCommit

impl Error for FailedCommit

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 FailedCommit

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FailedCommit