Enum ProducerError 

#[non_exhaustive]
pub enum ProducerError {
    Client(ClientError),
    Protocol(ProtocolError),
    Server(i16),
    FencedProducer,
    InvalidConfig(String),
    InvalidPartition(i32),
    InvalidTimestamp(i64),
    InvalidPartitionerResult(i32),
    BatchTooLarge {
        batch_size: usize,
    },
    RecordTooLarge {
        record_size: usize,
        limit: RecordSizeLimit,
    },
    BufferExhausted {
        size: usize,
        max_block: Duration,
        total: usize,
        available: usize,
        poolable: usize,
    },
    Closed,
    FlushTimeout,
    MetadataTimeout {
        topic: String,
        partition: Option<i32>,
        partition_count: Option<i32>,
        waited: Duration,
    },
    SendTimeout,
    Compression(CompressionError),
    NotTransactional,
    InvalidTransactionState(&'static str),
    TransactionAborted,
    ConcurrentTransactions,
    RecoveryRequired,
    FatalTransactionError(i16),
}

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.

Client(ClientError)

Protocol(ProtocolError)

Server(i16)

FencedProducer

InvalidConfig(String)

InvalidPartition(i32)

The record names a negative partition. Kafka’s ProducerRecord constructor throws IllegalArgumentException with the same message.

InvalidTimestamp(i64)

The record carries a negative timestamp. Kafka’s ProducerRecord constructor throws IllegalArgumentException with the same message.

InvalidPartitionerResult(i32)

A custom partitioner (partitioner.class) returned a negative partition. Kafka’s KafkaProducer.partition throws IllegalArgumentException with the same message.

BatchTooLarge

Fields

batch_size: usize

RecordTooLarge

The record is larger than a limit of the producer. Kafka’s KafkaProducer.ensureValidRecordSize throws RecordTooLargeException with the same message for each limit.

Fields

record_size: usize

Kafka’s upper bound of the serialized size of the record, in bytes.

limit: RecordSizeLimit

The limit that the record is larger than.

BufferExhausted

send waited max_block (the part of max_block that the metadata wait left) for buffer memory, and the memory did not become free. Kafka’s BufferPool.allocate throws BufferExhaustedException with the same message.

Fields

size: usize

max_block: Duration

total: usize

available: usize

poolable: usize

Closed

FlushTimeout

MetadataTimeout

send waited waited (the configured max_block) for metadata that holds the topic, and the partition of the record when it names one. Kafka’s KafkaProducer.waitOnMetadata throws TimeoutException with the same message.

Fields

topic: String

partition: Option<i32>

partition_count: Option<i32>

waited: Duration

SendTimeout

The batch ran out of retries, or its routing budget ended, before the broker acknowledged it. Kafka raises TimeoutException for the same case (Sender.sendProducerData and RecordAccumulator.expiredBatches).

Compression(CompressionError)

NotTransactional

InvalidTransactionState(&'static str)

TransactionAborted

The record’s batch was still queued in the accumulator, undrained, when the application aborted the transaction. Kafka’s Sender.maybeSendAndPollTransactionalRequest fails every undrained batch this way instead of sending it: accumulator.abortUndrainedBatches(new TransactionAbortedException()).

ConcurrentTransactions

RecoveryRequired

FatalTransactionError(i16)

A transaction coordinator answered with a fatal code, and the transactional producer can do no more transactional work. Every later init_transactions, begin_transaction, send, send_offsets_to_transaction, commit and abort fails with this error. Kafka’s TransactionManager moves to FATAL_ERROR for the same codes, and the application can only close the producer.

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

fn from(source: ClientError) -> Self

Converts to this type from the input type.

impl From<CompressionError> for ProducerError

fn from(source: CompressionError) -> Self

Converts to this type from the input type.

impl From<ProtocolError> for ProducerError

fn from(source: ProtocolError) -> Self

Converts to this type from the input type.