rdkafka_wrap/
wrap_err.rs

1use anyhow::Error as AnyhowErr;
2use rdkafka::error::{KafkaError, RDKafkaError};
3
4#[derive(thiserror::Error, Debug)]
5pub enum KWError {
6    #[error("rdkafka error")]
7    RdKafka(#[from] RDKafkaError),
8    #[error("kafka error")]
9    Kafka(#[from] KafkaError),
10    #[error("kafka-wrap error")]
11    Normal(#[from] AnyhowErr),
12}
13
14pub type KWResult<T> = Result<T, KWError>;