Schema Registry & Serdes

Non-blocking schema caching and serialization across Avro, Protobuf, and JSON Schema.

The Krabka schema clients implement the Confluent wire format with zero I/O on the hot serialization path:

  • Prewarming: Cache writer and reader schemas ahead of processing to ensure startup validity.
  • Non-blocking fetch: Unknown writer schema IDs encountered mid-stream trigger single background fetches with retriable error contracts.