crabka-protocol 0.2.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

//! KIP-631 metadata record layer: 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`. This is a permanent foundation (unlike the Slice 0 `kraft-spike`).

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

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