Package io.confluent.kafka.schemaregistry.storage
package io.confluent.kafka.schemaregistry.storage
-
ClassDescriptionAbstract base class for SchemaRegistry implementations that provides common state management and shared functionality.Internal class representing a raw schema with parsing options.InMemoryCache<K,
V> In-memory store based on mapsKafkaStore<K,V> Thread that reads schema registry state from the Kafka compacted topic and modifies the local store to be consistent.Internal interface for schema registry implementations.Runs theLogicalTypeCheckervalidity and compatibility checks thatCompatibilityPolicy.LOGICALadds on top of a schema's native compatibility check.LookupCache<K,V> Internal interface that provides various indexed methods that help lookup the underlying schemas.Simple wrapper for 16 byte MD5 hash.Metadata, which includes path annotations, arbitrary key-value properties, and a set of sensitive properties.This class saves out a map of topic/partition=>offsets to a file.This class read a map of topic/partition=>offsets from a file.Rule set, which includes migration rules (for migrating between versions), domain rules (for business logic), and encoding rules (for encoding logic).Kafka schema registry maintains a few in memory indices to facilitate schema lookups.The identity of a schema registry instance.An extension ofParsedSchemaHolderthat also provides access to the underlyingSchemaValue.Store<K,V> StoreUpdateHandler<K,V> TransformedIterator<F,T>