flier / tokio-kafka

Asynchronous Rust client for Apache Kafka
Apache License 2.0
31 stars 1 forks source link

Consumer: offset is not reset on OutOfRange #16

Open polachok opened 6 years ago

polachok commented 6 years ago

in fetcher.rs:188 state.need_offset_reset() is called, but it's never checked, so we keep trying to fetch bad offset.