Enum Error 

pub enum Error {
    Cancelled,
    Admin(AdminError),
    Consumer(ConsumerError),
    Producer(ProducerError),
    ConsumerGroupMetadata(ConsumerGroupMetadataError),
    TransactionState(TransactionStateError),
    Broker(BrokerError),
    Validation(ValidationError),
    Protocol(ProtocolError),
    Internal(Error),
}

Top-level error returned by the crate.

Variants

Cancelled

Operation was cancelled before it completed.

Admin(AdminError)

Admin operation failed.

Consumer(ConsumerError)

Consumer operation failed.

Producer(ProducerError)

Producer operation failed.

ConsumerGroupMetadata(ConsumerGroupMetadataError)

Consumer group metadata was invalid.

TransactionState(TransactionStateError)

Transaction state prevented the operation.

Broker(BrokerError)

A Kafka broker returned a protocol error code.

Validation(ValidationError)

Public input validation failed before a broker request was sent.

Protocol(ProtocolError)

The client could not decode or validate a Kafka protocol response.

Internal(Error)

Internal error from protocol handling, IO, or validation.

Implementations

impl Error

pub fn classification(&self) -> ErrorClassification

Classifies this error for retry and transaction recovery decisions.

pub fn is_retriable(&self) -> bool

Returns whether retrying the same operation may succeed.

pub fn is_fatal(&self) -> bool

Returns whether the client or transaction is permanently unusable.

pub fn transaction_abort_required(&self) -> bool

Returns whether the current transaction must be aborted before reuse.

Trait Implementations

impl Debug for Error

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

Formats the value using the given formatter.

impl Display for Error

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

Formats the value using the given formatter.

impl Error for Error

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 From<AdminError> for Error

fn from(source: AdminError) -> Self

Converts to this type from the input type.

impl From<BrokerError> for Error

fn from(source: BrokerError) -> Self

Converts to this type from the input type.

impl From<ConsumerError> for Error

fn from(source: ConsumerError) -> Self

Converts to this type from the input type.

impl From<ConsumerGroupMetadataError> for Error

fn from(source: ConsumerGroupMetadataError) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<ProducerError> for Error

fn from(source: ProducerError) -> Self

Converts to this type from the input type.

impl From<ProtocolError> for Error

fn from(source: ProtocolError) -> Self

Converts to this type from the input type.

impl From<TransactionStateError> for Error

fn from(source: TransactionStateError) -> Self

Converts to this type from the input type.

impl From<ValidationError> for Error

fn from(source: ValidationError) -> Self

Converts to this type from the input type.