ene_kafka/
lib.rs

1use rdkafka::client::DefaultClientContext;
2
3pub mod admins;
4pub mod consumers;
5pub mod dispatchers;
6pub mod handlers;
7pub mod messages;
8pub mod producers;
9
10pub type KafkaResult<T> = anyhow::Result<T>;
11
12#[cfg(feature = "rdkafka")]
13pub type ConsumerImpl = rdkafka::consumer::StreamConsumer;
14#[cfg(feature = "rdkafka")]
15pub type ProducerImpl = rdkafka::producer::FutureProducer;
16#[cfg(feature = "rdkafka")]
17pub type AdminImpl = rdkafka::admin::AdminClient<DefaultClientContext>;