Enum kafka_rs::error::ClientError

pub enum ClientError {
    BrokerError(BrokerRequestError),
    Disconnected,
    EncodingError(String),
    NoPartitionsAvailable(String),
    UnknownBroker(BrokerId),
    UnknownTopic(String),
}

Client errors from interacting with a Kafka cluster.

Variants

BrokerError(BrokerRequestError)

Error while interacting with a broker.

Disconnected

The client is disconnected.

EncodingError(String)

Error while encoding a batch of records.

NoPartitionsAvailable(String)

The specified topic has no available partitions.

UnknownBroker(BrokerId)

A broker has disappeared from the cluster during client operations.

Typically, application code should just retry the request in the face of this error.

UnknownTopic(String)

The specified topic is unknown to the cluster.

Trait Implementations

impl Debug for ClientError

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

Formats the value using the given formatter.

impl Display for ClientError

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

Formats the value using the given formatter.

impl Error for ClientError

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.