rust-rdkafka
rust-rdkafka copied to clipboard
fede1024
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Hello, This PR adds a callback logic for errors occurred on `poll` method call in producer. The idea is to handle several kinds of errors immediately. Here is a use...
Adds a simple function `ClientConfig.set_if` that wraps `ClientConfig.set` to allow for passing values that are options. This is helpful for configuring clients dynamically via config files that may or may...
This `StreamConsumer` racy behavior can be observed in the recent release, probably after the move to Event-based API. Some of the events (stats, logs etc.) are processed internally and are...
This (amongst other updates) will remove syn 1 for users that rely on this library in combination with tokio, speeding up build times. I did not update clap to not...
I'm fairly new to Rust and I've been trying to emit the C library kafka logs as tracing events, similar to what we can do with rust-rdkafka logs if we...
Some small refactors I found while tracking down another issue.
We are using rust rdkafka library as client to produce messages in kafka. version (0.31). Issue we face is whenever kafka broker gets restarted or there is some downtime for...
See https://docs.confluent.io/platform/7.5/clients/librdkafka/html/rdkafka_8h.html#ade8d161dfb86a94179d286f36ec5b28e
i want know a group_id has consumed how many offset on a topic. let offsets = admin_client.fetch_consumer_group_offsets(group_id, &[topic_name.to_string()], None).await?; in java,we have: kafkaAdminClient.listConsumerGroupOffsets(group_id).partitionsToOffsetAndMetadata().get();
