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.