ene_kafka 0.2.0

Ene Kafka is an easy-to-use Rust client for Apache Kafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use rdkafka::client::DefaultClientContext;

pub mod admins;
pub mod consumers;
pub mod dispatchers;
pub mod handlers;
pub mod messages;
pub mod producers;

pub type KafkaResult<T> = anyhow::Result<T>;

#[cfg(feature = "rdkafka")]
pub type ConsumerImpl = rdkafka::consumer::StreamConsumer;
#[cfg(feature = "rdkafka")]
pub type ProducerImpl = rdkafka::producer::FutureProducer;
#[cfg(feature = "rdkafka")]
pub type AdminImpl = rdkafka::admin::AdminClient<DefaultClientContext>;