All Classes and Interfaces

Class
Description
 
A broker-side AssociatedNameStrategy that replaces the parent's synchronous Guava cache with a Caffeine cache tuned for broker schema validation.
Non-blocking, cache-only lookups used by the async validation path.
Factories for the log samplers used to rate-limit per-record validation logging.
An implementation of SchemaRegistryClient that only supports SchemaRegistryClient.getSchemaBySubjectAndId(String, int) and SchemaRegistryClient.getId(String, ParsedSchema).
A RecordInterceptor that performs schema validation.
 
The parts of a Schema Registry client that are independent of how results are cached: the RestService and its construction-time wiring, retry handling, schema-provider setup and parsing, and the calls that pass straight through to Schema Registry.
Represents how the schema ID was resolved during validation.
Schema ID validation, shared by every caller that needs it.
Everything SchemaIdValidationCore needs to validate a record: which Schema Registry to ask, how to derive the subject, and what to validate.
Records validation metrics into Kafka Sensors.
Subject-name helpers shared by the schema validation core and the Schema Registry client wrappers.
Outcome of validating one record.
Sink for schema-validation metrics.