krabka-protocol 0.8.0

Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

//! KIP-631 metadata record layer.
//!
//! The layer is the `ApiMessageAndVersion` value envelope, a decode dispatch
//! over the generated record types, control-record framing, and a
//! `bootstrap.checkpoint` builder. Byte-compatible with apache/kafka 4.x
//! `KRaft`.

pub mod checkpoint;
pub mod control;
pub mod envelope;
pub mod record;

pub use envelope::{EnvelopeError, FRAME_VERSION, ValueHeader, decode_value_header, encode_value};
pub use record::{KraftMetadataRecord, UNKNOWN_FRAME_VERSION};