1 2 3 4 5 6 7
//! Core consumer implementation. pub mod offset_manager; pub mod poller; pub mod topic_consumer; pub use topic_consumer::{ConsumerBuilder, TopicConsumer};