rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Hi there, had a quick question about the expectations of using dynamic linking. The readme in `rdkafka-sys` claims: > The system version of librdkafka must exactly match the version of...
I try to discovery the partitions inside the topics I subscribed. Even if it looks simple, I could not manage it with this code ```rust #[test] fn test_partition() -> KafkaResult{...
I'm able to fairly regularly able to produce the issue using this sample program: https://github.com/penick/kafka_hang/blob/main/src/main.rs. This hang also manifests itself in the [Kafka Source](https://github.com/vectordotdev/vector/blob/v0.24.2/src/sources/kafka.rs) for Vector. Versions: v0.28.0 and v0.29.0...
CI(Build Status) and codecov(coverate) are not actual? Maybe remove or disable badges in `README.md`?
Hi, im trying to consume messages from kafka with rust-rdkafka. i copy pasted at_least_once.rs code but nothing gets consumed from kafka. in console i get following logs: ``` rebalance: RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS...
Upgraded to 0.36.2, and identified that rdkafka::error::RDKafkaErrorCode::QueueFull is continually returned after each send, even when explicitly calling BaseProducer.poll(). Additionally, explicit calls to BaseProducer.flush() leaves un-published events in queue - these...
I got the error log: ``` Creating library D:\Projects\rust\im-backend-rebuild\im-backend\target\debug\deps\cmd.lib and object D:\Projects\rust\im-backend-rebuild\im-backend\target\debug\deps\cmd.exp librdkafka_sys-0c6e3b2edcfc6e13.rlib(rdkafka_msgset_writer.obj) : error LNK2001: unresolved external symbol __imp_crc32 librdkafka_sys-0c6e3b2edcfc6e13.rlib(rdkafka_sticky_assignor.obj) : error LNK2001: unresolved external symbol __imp_crc32 librdkafka_sys-0c6e3b2edcfc6e13.rlib(rdkafka_fetcher.obj) :...
Commit 353812ff958b4b65f9e65dd22a60e770ed6ba948 replaced the more finicky `CStr::from_bytes_with_nul` with `String::from_utf8_lossy`. This causes tests to fail, both for me locally and in [CI](https://github.com/fede1024/rust-rdkafka/actions/runs/8417735908/job/23046767982). That commit eliminated a panic but now the returned...
This PR changes the `rdkafka-sys/build.rs` script to automatically choose CMake if the target platform is Windows. The `cmake-build` cargo feature no longer has an effect on Windows. It can still...
The trait `std::convert::From` is not implemented for `rdkafka::error::KafkaError`. It'd be nice to add that support
