Enum ProducerError 

pub enum ProducerError {
    IdempotenceRequiresAcksAll,
    IdempotenceRequiresRetries,
    TransactionalRequiresAcksAll,
    MissingTransactionVersionFeature,
    UnsupportedTransactionVersion {
        level: i16,
    },
    UnsupportedApiVersion {
        api: &'static str,
        min_version: i16,
        broker_version: i16,
    },
    NotTransactional,
    ThreadStoppedBefore {
        operation: &'static str,
    },
    ThreadStoppedDuring {
        operation: &'static str,
    },
    Join(JoinError),
}

Errors raised by the producer API.

Variants

IdempotenceRequiresAcksAll

Idempotence was enabled without acks=-1.

IdempotenceRequiresRetries

Idempotence was enabled without retries.

TransactionalRequiresAcksAll

Transactions require all replicas to acknowledge records.

MissingTransactionVersionFeature

The broker did not report the transaction feature level.

UnsupportedTransactionVersion

The broker transaction feature level is too old.

Fields

level: i16

Broker feature level.

UnsupportedApiVersion

A broker API version is older than this client needs.

Fields

api: &'static str

API name.

min_version: i16

Minimum required API version.

broker_version: i16

Version advertised by the broker.

NotTransactional

The operation requires a configured transactional id.

ThreadStoppedBefore

The sender task stopped before the operation was sent.

Fields

operation: &'static str

Operation that was waiting to be sent.

ThreadStoppedDuring

The sender task stopped while the operation was waiting for a reply.

Fields

operation: &'static str

Operation that was in flight.

Join(JoinError)

The sender task could not be joined.

Trait Implementations

impl Debug for ProducerError

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

Formats the value using the given formatter.

impl Display for ProducerError

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

Formats the value using the given formatter.

impl Error for ProducerError

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<ProducerError> for Error

fn from(source: ProducerError) -> Self

Converts to this type from the input type.