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.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>