1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
#[cfg(feature = "with_kafka")] extern crate kafka; #[macro_use] extern crate error_chain; mod varint; pub mod error; pub mod byte_consumer; pub mod converter; pub mod stream; #[cfg(feature = "with_kafka")] pub mod kafka_consumer;