Enum rdkafka::error::KafkaError
[−]
[src]
pub enum KafkaError {
ClientConfig(RDKafkaConfRes, String, String, String),
ClientCreation(String),
ConsumerCommit(RDKafkaError),
ConsumerCreation(String),
FutureCanceled,
Global(RDKafkaError),
GroupListFetch(RDKafkaError),
MessageConsumption(RDKafkaError),
MessageProduction(RDKafkaError),
MetadataFetch(RDKafkaError),
NoMessageReceived,
Nul(NulError),
OffsetFetch(RDKafkaError),
PartitionEOF(i32),
SetPartitionOffset(RDKafkaError),
StoreOffset(RDKafkaError),
Subscription(String),
}Represents all Kafka errors. Check the underlying RDKafkaError to get details.
Variants
ClientConfig(RDKafkaConfRes, String, String, String)ClientCreation(String)ConsumerCommit(RDKafkaError)ConsumerCreation(String)FutureCanceledGlobal(RDKafkaError)GroupListFetch(RDKafkaError)MessageConsumption(RDKafkaError)MessageProduction(RDKafkaError)MetadataFetch(RDKafkaError)NoMessageReceivedNul(NulError)OffsetFetch(RDKafkaError)PartitionEOF(i32)SetPartitionOffset(RDKafkaError)StoreOffset(RDKafkaError)Subscription(String)
Trait Implementations
impl Clone for KafkaError[src]
fn clone(&self) -> KafkaError[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
impl PartialEq for KafkaError[src]
fn eq(&self, __arg_0: &KafkaError) -> bool[src]
This method tests for self and other values to be equal, and is used by ==. Read more
fn ne(&self, __arg_0: &KafkaError) -> bool[src]
This method tests for !=.
impl Eq for KafkaError[src]
impl Debug for KafkaError[src]
impl Display for KafkaError[src]
fn fmt(&self, f: &mut Formatter) -> Result[src]
Formats the value using the given formatter. Read more
impl Error for KafkaError[src]
fn description(&self) -> &str[src]
A short description of the error. Read more
fn cause(&self) -> Option<&Error>[src]
The lower-level cause of this error, if any. Read more
impl From<NulError> for KafkaError[src]
fn from(err: NulError) -> KafkaError[src]
Performs the conversion.