Enum rdkafka::error::KafkaError

pub enum KafkaError {
    ClientConfig((RDKafkaConfRes, String, String, String)),
    ClientCreation(String),
    ConsumerCreation(String),
    MessageConsumption(RDKafkaRespErr),
    MessageProduction(RDKafkaRespErr),
    Nul(NulError),
    Subscription(String),
    TopicConfig((RDKafkaConfRes, String, String, String)),
    TopicCreation(String),
    PartitionEof,
}

Represents all Kafka errors.

Variants

ClientConfig((RDKafkaConfRes, String, String, String))ClientCreation(String)ConsumerCreation(String)MessageConsumption(RDKafkaRespErr)MessageProduction(RDKafkaRespErr)Nul(NulError)Subscription(String)TopicConfig((RDKafkaConfRes, String, String, String))TopicCreation(String)PartitionEof

Trait Implementations

impl Debug for KafkaError

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

Formats the value using the given formatter.

impl From<NulError> for KafkaError

fn from(err: NulError) -> KafkaError

Performs the conversion.