Kafka Rust Client
Documentation
Kafka Rust Client Documentation
The documentation includes some examples too.
Installation
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):
[]
= "*"
Usage:
Load topic metadata:
extern crate kafka;
use KafkaClient;
Fetch Offsets:
extern crate kafka;
use KafkaClient;
Produce:
extern crate kafka;
use KafkaClient;
Fetch Messages:
extern crate kafka;
use KafkaClient;
TODO:
- Test
- Remove unnecessary imports and publics
- Tests
- Missing functions for the implemented methods (eg. Fetch Message by multiple topic/partition)
- Offset Management functions
- Documentation