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
13
14
15
16
17
18
19
20
21
22

//! Typed v2 record batch decoder/encoder.
//!
//! See `docs/superpowers/specs/2026-05-11-crabka-records-1c-design.md`.
//! v0/v1 record batches are deferred to `crabka-log`.

pub(crate) mod borrowed;
mod crc;
mod error;
pub mod header;
pub mod metadata;
pub(crate) mod owned;
mod payload;

pub use borrowed::{
    Record as RecordBorrowed, RecordBatch as RecordBatchBorrowed,
    RecordHeader as RecordHeaderBorrowed,
};
pub use error::RecordsError;
pub use header::HEADER_LEN;
pub use header::{Attributes, RecordBatchHeader, TimestampType};
pub use owned::{Record, RecordBatch, RecordHeader};
pub use payload::{RecordsPayload, RecordsPayloadBorrowed};