Crate crabka_schema_serde 

Confluent-compatible schema serdes for Crabka clients.

Frames payloads as magic(0x00) | schema_id(4 BE) | body (plus a Protobuf message-index), with schemas registered against and resolved from a Confluent-compatible Schema Registry. Client-agnostic: the typed serializers here are bridged into crabka-client-streams (and later other clients).

Re-exports

pub use cache::CacheConfig;

pub use cache::RegisterMode;

pub use cache::SchemaCache;

pub use cache::default_registry;

pub use cache::set_default_registry;

pub use error::SchemaSerdeError;

pub use registry::RegistryClient;

pub use subject::Role;

pub use subject::SchemaKind;

pub use subject::SubjectStrategy;

pub use subject::TopicNameStrategy;

Modules

cache

Shared, background-refreshed schema cache. Hot-path reads are synchronous; registry I/O happens at pre-warm and on background fetches.

error

Error type for schema serdes.

format

Per-format typed serializers/deserializers. Each format owns the body encoding; framing + id resolution are shared here.

registry

Async Confluent Schema Registry REST client.

subject

Subject naming. Confluent’s default TopicNameStrategy maps a topic + key/value role to <topic>-key / <topic>-value.

wire

Confluent wire framing: magic(0x00) | schema_id(4 BE) | [msg_index] | body.