Struct ConsumerCommitFailedError 

pub struct ConsumerCommitFailedError { /* private fields */ }

An offset commit could not be completed because the group rebalanced.

Corresponds to Java’s CommitFailedException. It has no entry in Errors, so it carries no protocol code.

Java extends chain: CommitFailedException -> KafkaException

Note it extends KafkaException directly, so it is NOT an ApiException — unlike its sibling ConsumerRetriableCommitFailedError, which goes through RetriableException.

Implementations

impl ConsumerCommitFailedError

pub const CONSUMER_COMMIT_FAILED_DEFAULT_MESSAGE: &str = "Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records."

Default message used by Java’s CommitFailedException no-arg constructor.

Kept as a constant so tests can assert exact equality.

pub fn new(message: impl Into<String>) -> Self

Create the error with the given message.

pub fn with_default_message() -> Self

Create the error with Java’s no-arg constructor message.

pub fn message(&self) -> &str

The error message.

impl ConsumerCommitFailedError

pub fn source(&self) -> Option<&Error>

Always None: CommitFailedException exposes no Throwable cause constructor, so its cause is null in Java too. Present as an inherent method so it shadows both ErrorSource::source and std::error::Error::source, keeping x.source() unambiguous and typed.

Trait Implementations

impl Clone for ConsumerCommitFailedError

fn clone(&self) -> ConsumerCommitFailedError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerCommitFailedError

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

Formats the value using the given formatter.

impl Display for ConsumerCommitFailedError

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

Formats the value using the given formatter.

impl Error for ConsumerCommitFailedError

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.