1 2 3 4 5 6 7 8 9 10 11 12 13 14
//! Kafka backend for reinhardt-streaming. //! //! Requires feature `kafka`. /// Kafka connection configuration. pub mod config; /// Kafka consumer wrapper. pub mod consumer; /// Kafka producer wrapper. pub mod producer; pub use config::KafkaConfig; pub use consumer::KafkaConsumer; pub use producer::KafkaProducer;