Package io.krabka.streams.schema
package io.krabka.streams.schema
Confluent-wire-compatible Avro, Protobuf, and JSON Schema serdes.
Example
var client = new KrabkaSchemaRegistryClient(URI.create("http://localhost:8081"));
var cache = new SchemaCache(client);
var serde = JsonSchemaSerde.forValue(Order.class, orderSchema, cache, true);
serde.registerSubject("orders");
cache.prewarm().join();
-
ClassDescriptionAvroSerde<T>A Kafka serde for Confluent-framed Avro values.Encodes and decodes Confluent schema registry frames.A decoded frame.A decoded Protobuf frame.A Kafka serde for Confluent-framed JSON Schema values.A nonblocking client for the Confluent Schema Registry REST API.A schema fetched by ID, with unresolved references.One registered version of a subject.A schema fetched by ID with every transitive reference resolved to its text.A reference from one schema to a version of another subject.Pairwise, network-free schema compatibility checks.The direction of a compatibility check, mirroring registry compatibility levels.The outcome of one compatibility check.ProtobufSerde<T extends com.google.protobuf.Message>A Kafka serde for Confluent-framed Protobuf messages.Defines how prewarming resolves a schema ID.Identifies whether a schema belongs to a record key or value.Stores schema IDs and writer schemas for synchronous serde operations.The per-subject outcome of
SchemaCache.prewarmReport().Signals that a background writer-schema fetch has not completed.Schema formats supported by the registry client.Reports a schema registry transport, status, or response error.Maps a topic and record role to a schema registry subject.Uses the Confluent topic naming rule.