All Classes and Interfaces
Class
Description
Abstract base class for SchemaRegistry implementations that provides common state management
and shared functionality.
Internal class representing a raw schema with parsing options.
Indicates a schema already exists with a different ID.
Internal interface used for generating id while registering schema.
Indicates the schema is incompatible with the registered schema
In-memory store based on maps
Indicates an invalid schema that does not conform to the expected format of the schema
Indicates that the version is not a valid version id.
This class is intended to catch Early EOF errors that occur when the client disconnects
while the server is reading from the input stream.
A
WriterInterceptor to swallow EofException which
occurs when a client disconnects before the complete response could be sent.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.
Local implementation of SchemaRegistryClient that can be used without going through HTTP.
Internal interface that provides various indexed methods that help lookup the underlying schemas.
Deprecated.
Simple wrapper for 16 byte MD5 hash.
Metadata, which includes path annotations, arbitrary key-value properties,
and a set of sensitive properties.
Allows for adding and replacing custom headers in the HttpServletRequest object.
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.
The requested operation is not permitted.
Indicates the schema cannot be deleted because another schema references it.
Indicates that the context is not empty when it is expected to be.
Indicates that the ID of an imported schema does not match the existing ID.
An exception thrown when the registered schema is not compatible with the latest schema according
to the compatibility level.
Indicates an invalid association property value
Indicates an invalid schema that does not conform to the expected format of the schema
Indicates an invalid subject name
Indicates that the version is not a valid version id.
Indicates a reference exists to the given schema, so it cannot be deleted.
Indicates a problem while forwarding the request to the leader node in a schema
registry cluster
Indicates some error while performing a schema registry operation
Indicates an error while performing an operation on the underlying data store that
stores all schemas in the registry
Indicates that some schema registry operation timed out.
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.
A range of schema IDs, from the first available ID to the inclusive upper bound.
Indicates some error while performing a schema registry operation
The identity of a schema registry instance.
Indicates an error while initializing schema registry
Indicates an error while forwarding a write request to the leader node in a schema
registry cluster
Indicates an error while performing an operation on the underlying data store that
stores all schemas in the registry
Indicates that some schema registry operation timed out.
An extension of
ParsedSchemaHolder that also provides access to the underlying
SchemaValue.Error while (de)serializing data while reading from or writing to a
*
io.confluent.kafka.schemaregistry.storage.StoreError while performing an operation on a
*
io.confluent.kafka.schemaregistry.storage.StoreError while initializing a
io.confluent.kafka.schemaregistry.storage.StoreIndicates either a write, read or a bootstrap operation on the underlying Kafka store timed out.
RecordBuilder for Subrecord instances.
Indicates that the node that is asked to serve the request is not the current leader and
is not aware of the leader node to forward the request to
A valid version id should be a positive integer between 1 and 2^31-1.
SchemaRegistryMainKeep this class in place for compatibility.