rdkafka

library0.39.0rscratesunverified

Rust wrapper for librdkafka, providing a Kafka client library.

# Cargo.toml
[dependencies]
rdkafka = "0.39.0"

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · RDKAFKA

rdkafka

messagingrustv0.39.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

StreamConsumer

✓ use rdkafka::consumer::StreamConsumer;

Create a Kafka consumer and subscribe to a topic.

use rdkafka::consumer::{Consumer, StreamConsumer}; use rdkafka::ClientConfig; fn main() { let consumer: StreamConsumer = ClientConfig::new() .set("bootstrap.servers", "localhost:9092") .set("group.id", "example") .create() .expect("Consumer creation failed"); consumer.subscribe(&["test"]).unwrap(); println!("Consumer subscribed to topic 'test'"); }

Debug

Known issues

gotchaRequires librdkafka system library: this crate depends on the C library librdkafka.

fix

Install librdkafka via your system package manager (e.g., apt install librdkafka-dev).

affects: >=0.1.0

Upgrade

Version history

0.39.0latest on crates.io

Audit

Dependencies

No dependency data recorded yet.

Agent activity

16 hits · last 30 days

node

Amazon

OpenAI (training)

Resources

githubhttps://github.com/fede1024/rust-rdkafka ↗

homepagehttps://github.com/fede1024/rust-rdkafka ↗

docshttps://docs.rs/rdkafka/ ↗