rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Hi, Below code is copy pasted from the test cases of this project. Either the consumer is attached to kafka as `subscriber` or `assigned` (in both cases `auto.offset.reset` is set...
When calling the subscribe function with a vec of &str, to subscribe to multiple topics, there is no way to know which topic subscription causes a failure in the case...
## Issue description We're using `rdkafka` in our rust project and it fails to compile on `x86_64-unknown-linux-musl` if the `cmake` crate version is > `0.1.48`. On checking this issue, we...
### When using rdkafka feature `ssl-vendored` instead of `ssl`, kafka consumer fails to connect to a SASL auth-enabled Confluent Cloud cluster, and no messages are consumed - Minimal reproducible example...
Test implementation for PR https://github.com/fede1024/rust-rdkafka/pull/184
Hi, I am using `apache_avro` Rust lib to work with Avro data. Records are represented in this library with the following struct: https://docs.rs/apache-avro/0.14.0/apache_avro/types/enum.Value.html, this value can be converted to bytes...
For some reason librdkafka's cmake build does not enable snappy compression support. This enables snappy unconditionally (because anyway it is not an external dependency)
Resolves https://github.com/fede1024/rust-rdkafka/issues/572
Was wondering if there was an active reason against deriving Debug here. If there is no worries, I've got a fork im building off and I can also skip debug...
