kafrust-protocol 0.2.0

Kafka wire protocol primitives for kafrust.
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

#![forbid(unsafe_code)]

//! Kafka wire protocol support for kafrust.
//!
//! This crate is intentionally runtime-free. It owns Kafka request/response
//! encoding and decoding so the public client can stay focused on user-facing
//! producer and consumer behavior.

pub mod api;
pub mod codec;
pub mod consumer_group;
pub mod error;
pub mod frame;
pub mod header;

pub use error::{Error, Result};

/// Returns the protocol 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"));
    }
}