Kafka Rust Client Documentation
The documentation includes some examples too.
This crate works with Cargo and is on crates.io. I will be updating the package frequently till we move out of pre-release. So add this to your Cargo.toml (instead of a specific version):
toml
[dependencies]
kafka = "*"
rust
extern crate kafka;
use kafka::client::KafkaClient;
fn main() {
let mut client = KafkaClient::new(&vec!("localhost:9092".to_string()));
client.load_metadata(&vec!("my-topic".to_string()));
// OR
// client.load_metadata_all(); // Loads metadata for all topics
}
rust
extern crate kafka;
use kafka::client::KafkaClient;
fn main() {
let mut client = KafkaClient::new(&vec!("localhost:9092".to_string()));
client.load_metadata_all();
println!("{:?}", client.fetch_topic_offset(&"my-topic".to_string()));
}
rust
extern crate kafka;
use kafka::client::KafkaClient;
fn main() {
let mut client = KafkaClient::new(&vec!("localhost:9092".to_string()));
client.load_metadata_all();
// Currently only supports sending a single message
client.send_message(
&"my-topic".to_string(), // Topic
0, // Partition
1, // Required Acks
100, // Timeout
&"b".to_string().into_bytes() // Message
)
}
rust
extern crate kafka;
use kafka::client::KafkaClient;
fn main() {
let mut client = KafkaClient::new(&vec!("localhost:9092".to_string()));
client.load_metadata_all();
// Topic, partition, offset
for om in client.fetch_messages(&"my-topic".to_string(), 0, 0) {
println!("{:?}", om);
};
}