krabka-protocol 0.7.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`.

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};