This repository was archived by the owner on Nov 8, 2023. It is now read-only.
This repository was archived by the owner on Nov 8, 2023. It is now read-only.
Consider the async io api provided by the streaming consumer #6
Description
Consider using async io for processing the messages in the consumer
https://github.com/fede1024/rust-rdkafka/blob/master/examples/asynchronous_processing.rs