Skip to main content

rustfs_kafka/
lib.rs

1//! Clients for communicating with a [Kafka](http://kafka.apache.org/)
2//! cluster.  These are:
3//!
4//! - `rustfs_kafka::producer::Producer` - for sending message to Kafka
5//! - `rustfs_kafka::consumer::Consumer` - for retrieving/consuming messages from Kafka
6//! - `rustfs_kafka::client::KafkaClient` - a lower-level, general purpose client leaving
7//!   you with more power but also more responsibility
8//!
9//! See module level documentation corresponding to each client individually.
10#![recursion_limit = "128"]
11#![deny(clippy::all)]
12#![warn(clippy::pedantic)]
13
14pub mod client;
15mod compression;
16pub mod consumer;
17pub mod error;
18#[cfg(feature = "metrics")]
19mod metrics;
20mod network;
21pub mod producer;
22mod protocol;
23mod utils;
24
25#[cfg(feature = "security")]
26mod tls;
27
28pub use self::error::{Error, Result};