rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Hi, fede1024 We have a scenario when using `rust-rdkafka`, first we use `tokio` as an asynchronous framework, so we choose a high level consumer, so we can use `stream()` for...
I’m basically looking for an example of how to achieve the same thing here: https://www.confluent.io/blog/transactions-apache-kafka/ Thanks for all the hard work on this crate.
This would give a good idea of the overhead compared to rdkafka itself.
Hi, we're using rust-rdkafka at @braiins . However, we found out that we probably wouldn't like to use the interface as is because of the requirement to spin up threads...
I have a use case where I would like to parallelize consuming from a single rdkafka consumer. I have a static set of partitions that I would like to subdivide...
As per https://github.com/edenhill/librdkafka/issues/1773 `DeleteRecords` was added to rdkafka in 1.6.0. This functionality is not yet mapped to Rust.
There is a crash in rust-rdkafka that panics the program with an `Illegal instruction`. It is not easy to reproduce but it seems to be related to Kafka disconnecting and...
Hello, This [dependabot commit](https://github.com/fede1024/rust-rdkafka/commit/b4e13e71d5ea54028ac31d06a0102257e51c810c) is a pretty important change for our use case and might warrant a new version of the crate with a new tag. Changing major version here,...
Hello there, I'm trying to get all the data from the Kafka topic from the beginning. I set the `auto.offset.reset` flag to earliest and `group.id` to a random string, this...
