flier / tokio-kafka

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

Use existing assignment if found #28

Closed polachok closed 6 years ago

polachok commented 6 years ago

Position is reset to 0 otherwise

I'm running a consumer with this and #27 for 24 hours and it finally seems to work as intended (no lag, no duplicates).

flier commented 6 years ago

great, thanks