Enum mz_kafka_util::client::MzKafkaError

pub enum MzKafkaError {
    InvalidCredentials,
    InvalidCACertificate,
    SSLEncryptionMaybeRequired,
    SSLUnsupported,
    BrokerCertificateMissing,
    InvalidBrokerCertificate,
    ConnectionReset(String),
    ConnectionTimeout,
    HostnameResolutionFailed,
    UnsupportedSASLMechanism,
    UnsupportedBrokerVersion,
    BrokerTransportFailure,
    AllBrokersDown,
    SaslAuthenticationRequired,
    SaslAuthenticationFailed,
    SslAuthenticationRequired,
    UnknownTopicOrPartition,
    Internal(String),
}

A structured error type for errors reported by librdkafka through its logs.

Variants

InvalidCredentials

Invalid username or password

InvalidCACertificate

Missing CA certificate

SSLEncryptionMaybeRequired

Broker might require SSL encryption

SSLUnsupported

Broker does not support SSL connections

BrokerCertificateMissing

Broker did not provide a certificate

InvalidBrokerCertificate

Failed to verify broker certificate

ConnectionReset(String)

Connection reset

ConnectionTimeout

Connection timeout

HostnameResolutionFailed

Failed to resolve hostname

UnsupportedSASLMechanism

Unsupported SASL mechanism

UnsupportedBrokerVersion

Unsupported broker version

BrokerTransportFailure

Connection to broker failed

AllBrokersDown

All brokers down

SaslAuthenticationRequired

SASL authentication required

SaslAuthenticationFailed

SASL authentication required

SslAuthenticationRequired

SSL authentication required

UnknownTopicOrPartition

Unknown topic or partition

Internal(String)

An internal kafka error

Trait Implementations

impl Clone for MzKafkaError

fn clone(&self) -> MzKafkaError

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MzKafkaError

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

Formats the value using the given formatter.

impl Display for MzKafkaError

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

Formats the value using the given formatter.

impl Error for MzKafkaError

fn source(&self) -> Option<&(dyn Error + 'static)>

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 FromStr for MzKafkaError

type Err = ()

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl PartialEq for MzKafkaError

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for MzKafkaError

impl StructuralPartialEq for MzKafkaError