Skip to main content

flowly_kafka/
error.rs

1use rdkafka::error::KafkaError;
2use thiserror::Error;
3
4#[derive(Error, Debug)]
5pub enum Error<E> {
6    #[error("No connection: Attempting to send or receive without an established connection")]
7    NoConnection,
8
9    #[error("Kafka error: {0}")]
10    KafkaError(#[from] KafkaError),
11
12    #[error("Message encode/decode error: {0}")]
13    MessageCodecError(E),
14
15    #[error("Kafka try connection limit: {0:?}")]
16    TryConnectionLimit(Option<Box<Error<E>>>),
17}