1
2
3
4
5
6
7
8
9
10
11
12

mod consumer;
pub(crate) mod status;

pub(crate) use consumer::KafkaConsumerThread;

use crate::errors::Error;

impl From<rdkafka::error::KafkaError> for Error {
    fn from(error: rdkafka::error::KafkaError) -> Self {
        Error::Consumer(error.to_string())
    }
}