rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
I am trying to use rust-rdkafka into my project. I added the following dependency to my `cargo.toml` ``` [package] name = "rust_fair_scheduler" version = "0.1.0" edition = "2021" # See...
Im using AWS lambda consumer and if I do autocommit false, I need to able to submit it, but have no consumer there as its aws lambda. I just need...
I would like use poll with a specified timeout but i would like to get N number of messages per call. And poll other messages in the next call. ```rust...
I've tried to implement a simple microservice application that consumes a Kafka topic, but it seems it is not working. # Expected Behavior You should see the Rust application printing...
I tried running the `simple_consumer` example in the examples folder but the messages are not printed in the console. The issue does not seem to be with my kafka running...
The following Cargo.toml still requires a system install of the dependencies of cyrus-ssl ``` [package] name = "foo" version = "0.1.0" edition = "2021" # See more keys and their...
Due to https://rustsec.org/advisories/RUSTSEC-2023-0001 we should upgrade tokio to 1.24 ASAP if possible.
I am getting this failure: ``` running: "cmake" "/usr/ports/databases/materialize/work/rust-rdkafka-8ea07c4d2b96636ff093e670bc921892aee0d56a/rdkafka-sys/librdkafka" "-DRDKAFKA_BUILD_STATIC=1" "-DRDKAFKA_BUILD_TESTS=0" "-DRDKAFKA_BUILD_EXAMPLES=0" "-DCMAKE_INSTALL_LIBDIR=lib" "-DWITH_ZLIB=1" "-DWITH_CURL=0" "-DWITH_SSL=1" "-DWITH_SASL_SCRAM=1" "-DWITH_SASL_OAUTHBEARER=1" "-DWITH_SASL=0" "-DWITH_ZSTD=1" "-DENABLE_LZ4_EXT=0" "-DCMAKE_INSTALL_PREFIX=/usr/ports/databases/materialize/work/target/release/build/rdkafka-sys-ee3c7cdabebb9f9d/out" "-DCMAKE_C_FLAGS= -ffunction-sections -fdata-sections -fPIC -m64 -pipe -fstack-protector-strong -fno-strict-aliasing"...
Good morning. Thanks for a great library! It seems to me there's an error in the function signature of the `FromBytes` trait, it's specified to return a reference to a...
# Problem After calling [split_partition_queue](https://docs.rs/rdkafka/0.29.0/rdkafka/consumer/stream_consumer/struct.StreamConsumer.html#method.split_partition_queue) on consumer (both `StreamConsumer` and `BaseConsumer` have same problem) when this `PartitionQueue` is dropped, it is impossible to get retreive messages (maybe unless i call...
