[−]Enum kafka::error::ErrorKind

pub enum ErrorKind {
    Msg(String),
    Io(Error),
    Ssl(SslError),
    InvalidSnappy(Error),
    Kafka(KafkaCode),
    TopicPartitionError(String, i32, KafkaCode),
    UnsupportedProtocol,
    UnsupportedCompression,
    UnexpectedEOF,
    CodecError,
    StringDecodeError,
    NoHostReachable,
    NoTopicsAssigned,
    InvalidDuration,
}

The kind of an error.

Variants

Msg(String)

A convenient variant for String.

Io(Error)

Input/Output error while communicating with Kafka

Ssl(SslError)

An error as reported by OpenSsl

InvalidSnappy(Error)

Failure to encode/decode a snappy compressed response from Kafka

Kafka(KafkaCode)

An error as reported by a remote Kafka server

TopicPartitionError(String, i32, KafkaCode)

An error when transmitting a request for a particular topic and partition. Contains the topic and partition of the request that failed, and the error code as reported by the Kafka server, respectively.

UnsupportedProtocol

Failure to correctly parse the server response due to the server speaking a newer protocol version (than the one this library supports)

UnsupportedCompression

Failure to correctly parse the server response by this library due to an unsupported compression format of the data

UnexpectedEOF

Failure to decode a response due to an insufficient number of bytes available

CodecError

Failure to decode or encode a response or request respectively

StringDecodeError

Failure to decode a string into a valid utf8 byte sequence

NoHostReachable

Unable to reach any host

NoTopicsAssigned

Unable to set up Consumer due to missing topic assignments

InvalidDuration

An invalid user-provided duration

Methods

`impl ErrorKind`

`pub fn description(&self) -> &str`

A string describing the error kind.

Trait Implementations

`impl From<ErrorKind> for Error`

`fn from(e: ErrorKind) -> Self`

`impl<'a> From<&'a str> for ErrorKind`

`fn from(s: &'a str) -> Self`

`impl From<String> for ErrorKind`

`fn from(s: String) -> Self`

`impl From<Error> for ErrorKind`

`fn from(e: Error) -> Self`

`impl Display for ErrorKind`

`fn fmt(&self, fmt: &mut Formatter) -> Result`

`impl Debug for ErrorKind`

`fn fmt(&self, f: &mut Formatter) -> Result`

Auto Trait Implementations

`impl Unpin for ErrorKind`

`impl Sync for ErrorKind`

`impl Send for ErrorKind`

`impl !UnwindSafe for ErrorKind`

`impl !RefUnwindSafe for ErrorKind`

Blanket Implementations

`impl<T> ToString for T where T: Display + ?Sized,` [src]

`default fn to_string(&self) -> String`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`fn into(self) -> U`[src]

`impl<T> From<T> for T`[src]

`fn from(t: T) -> T`[src]

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

[−]Enum kafka::error::ErrorKind

Variants

Methods

impl ErrorKind

pub fn description(&self) -> &str

Trait Implementations

impl From<ErrorKind> for Error

fn from(e: ErrorKind) -> Self

impl<'a> From<&'a str> for ErrorKind

fn from(s: &'a str) -> Self

impl From<String> for ErrorKind

fn from(s: String) -> Self

impl From<Error> for ErrorKind

fn from(e: Error) -> Self

impl Display for ErrorKind

fn fmt(&self, fmt: &mut Formatter) -> Result

impl Debug for ErrorKind

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

Auto Trait Implementations

impl Unpin for ErrorKind

impl Sync for ErrorKind

impl Send for ErrorKind

impl !UnwindSafe for ErrorKind

impl !RefUnwindSafe for ErrorKind

Blanket Implementations

impl<T> ToString for T where T: Display + ?Sized, [src]

default fn to_string(&self) -> String[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

fn into(self) -> U[src]

impl<T> From<T> for T[src]

fn from(t: T) -> T[src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

fn borrow_mut(&mut self) -> &mut T[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

fn borrow(&self) -> &T[src]

impl<T> Any for T where T: 'static + ?Sized, [src]

fn type_id(&self) -> TypeId[src]

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

`impl ErrorKind`

`pub fn description(&self) -> &str`

`impl From<ErrorKind> for Error`

`fn from(e: ErrorKind) -> Self`

`impl<'a> From<&'a str> for ErrorKind`

`fn from(s: &'a str) -> Self`

`impl From<String> for ErrorKind`

`fn from(s: String) -> Self`

`impl From<Error> for ErrorKind`

`fn from(e: Error) -> Self`

`impl Display for ErrorKind`

`fn fmt(&self, fmt: &mut Formatter) -> Result`

`impl Debug for ErrorKind`

`fn fmt(&self, f: &mut Formatter) -> Result`

`impl Unpin for ErrorKind`

`impl Sync for ErrorKind`

`impl Send for ErrorKind`

`impl !UnwindSafe for ErrorKind`

`impl !RefUnwindSafe for ErrorKind`

`impl<T> ToString for T where T: Display + ?Sized,` [src]

`default fn to_string(&self) -> String`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`fn into(self) -> U`[src]

`impl<T> From<T> for T`[src]

`fn from(t: T) -> T`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`fn borrow(&self) -> &T`[src]

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`fn type_id(&self) -> TypeId`[src]

`impl<V, T> VZip<V> for T where V: MultiLane<T>,`

`fn vzip(self) -> V`