rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
[Docs](https://docs.rs/rdkafka/0.36.2/rdkafka/consumer/stream_consumer/struct.StreamConsumer.html#method.split_partition_queue) about `split_partition_queue` says that >Note that calling [Consumer::assign](https://docs.rs/rdkafka/0.36.2/rdkafka/consumer/trait.Consumer.html#tymethod.assign) will deactivate any existing partition queues. You will need to call this method for every partition that should be split after...
please i need rust equivalent for this here is go equivalent for producer ``` package main import ( "context" "crypto/tls" "crypto/x509" "fmt" "io/ioutil" "log" "time" "github.com/segmentio/kafka-go" ) func main() {...
**Note:** This is an API breaking change. Currently the `Timestamp` value is being dropped as part of the conversion from `BorrowedMessage` to `OwnedDeliveryResult`, however this value is updated once the...
When creating a StreamConsumer with the `allow.auto.create.topics` option set to `true` and subscribing to a topic that doesn't exist yet, the error `UnknownTopicOrPartition (Broker: Unknown topic or partition)` is thrown....
I'll start by noting that whilst this is an issue, `tokio` doesn't currently support a clean solution for this, so it may not be something you want to resolve. ##...
https://github.com/fede1024/rust-rdkafka/pull/587 introduced a regression on MacOS. Using `CStr:: from_bytes_until_nul` fixes it and should fix the OP's issue as well.
**Note:** Currently based on #647 to pull in the regression fix This PR adds a new consumer function - `get_watermark_offsets` - which leverages the [get_watermark_offsets](https://docs.confluent.io/platform/current/clients/librdkafka/html/classRdKafka_1_1Handle.html#ab37fddad61506c8749214f1f009d17ca) librdkafka binding to return the...
Would it be possible to support committing with `OwnedMessage` as well? Say you have an async environment where all interactions are messages being passed around. The expectation of having a...
I am trying to commit a message using Stream Consumer. But, getting the problem that consumer does not live long enough. Tried using Arc Mutex as well, but it ends...
I have this in Cargo toml rdkafka = { version = "0.29.0", features = [ "ssl", "cmake-build"] } I tried to compile to x86_64-unknown-linux-musl using 2 options. Both failed. 1....
