This repository has been archived by the owner on Nov 8, 2023. It is now read-only.

Consider the async io api provided by the streaming consumer #6

Open

fpacifici opened this issue Apr 21, 2022 · 0 comments

Collaborator

fpacifici commented Apr 21, 2022

Consider using async io for processing the messages in the consumer
https://github.com/fede1024/rust-rdkafka/blob/master/examples/asynchronous_processing.rs

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.