kafrust 0.1.0

A pure Rust Kafka client with no librdkafka or C toolchain dependency.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

#![doc = include_str!("../README.md")]
#![forbid(unsafe_code)]
#![warn(missing_docs)]

/// Low-level Kafka request client.
pub mod client;
/// Shared connection configuration.
pub mod config;
/// Direct topic/partition consumer API.
pub mod consumer;
/// Error and result types.
pub mod error;
/// Classic consumer group alpha API.
pub mod group;
/// Producer API.
pub mod producer;

pub use client::Client;
pub use config::ClientConfig;
pub use consumer::{Consumer, ConsumerAssignment, ConsumerConfig, ConsumerRecord};
pub use error::{BrokerErrorKind, Error, Result};
pub use group::{ConsumerGroup, ConsumerGroupConfig, ConsumerGroupHeartbeat};
pub use kafrust_protocol as protocol;
pub use producer::{Acks, Header, ProducerConfig, ProducerRecord, RecordMetadata};

/// Returns the crate version compiled into this build.
pub fn version() -> &'static str {
    env!("CARGO_PKG_VERSION")
}

#[cfg(test)]
mod tests {
    #[test]
    fn exposes_crate_version() {
        assert_eq!(crate::version(), env!("CARGO_PKG_VERSION"));
    }
}