Enum kafka::error::ErrorKind
[−]
pub enum ErrorKind { Msg(String), Io(Error), Ssl(SslError), SslHandshake(ErrorStack), 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
SslHandshake(ErrorStack)
An error as reported by OpenSsl handshake
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
fn description(&self) -> &str
A string describing the error kind.