Crate kafka_rs

Source

Re-exports§

pub use client::Acks;
pub use client::Client;
pub use client::ListOffsetsPosition;
pub use client::Message;
pub use client::TopicProducer;
pub use kafka_protocol;
pub use kafka_protocol::indexmap;

Modules§

client
Kafka client implementation.
error
Crate error types.

Structs§

IndexMap
A hash table where the iteration order of the key-value pairs is independent of the hash values of the keys.
Record
A Kafka message containing key, payload value, and all associated metadata.
StrBytes
A string type backed by Bytes.

Enums§

Compression
The different types of compression supported by Kafka.