Index

A B C D F G H I K L M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.validator

AbstractSchemaRegistryClient() - Constructor for class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

ACCEPT - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.ValidationDecision

The record passed validation and may be appended.

all() - Static method in class io.confluent.kafka.schemaregistry.validator.core.LoggingSamplers

A sampler that logs every event.

ASSOCIATION_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

ASSOCIATION_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

ASSOCIATION_CACHE_TTL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

ASYNC_SCHEMA_VALIDATION_ENABLED_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

ASYNC_SCHEMA_VALIDATION_ENABLED_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

asyncValidationEnabled() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Whether validation may answer from cache and return ValidationDecision.RETRY.

asyncValidationEnabled() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

B

baseRecordSchemaValidatorConfigDef() - Static method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BASIC_AUTH_CREDENTIALS_SOURCE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BASIC_AUTH_CREDENTIALS_SOURCE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BASIC_AUTH_CREDENTIALS_SOURCE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CLIENT_ID - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CLIENT_ID_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CLIENT_SECRET - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CLIENT_SECRET_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CREDENTIALS_SOURCE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CREDENTIALS_SOURCE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_CREDENTIALS_SOURCE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_IDENTITY_POOL_ID - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_IDENTITY_POOL_ID_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_ISSUER_ENDPOINT_URL - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_ISSUER_ENDPOINT_URL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_LOGICAL_CLUSTER - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_LOGICAL_CLUSTER_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SCOPE - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SCOPE_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SCOPE_CLAIM_NAME_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SCOPE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SUB_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_SUB_CLAIM_NAME_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_TOKEN_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_TOKEN_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BEARER_AUTH_TOKEN_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

BrokerAssociatedNameStrategy - Class in io.confluent.kafka.schemaregistry.validator

A broker-side AssociatedNameStrategy that replaces the parent's synchronous Guava cache with a Caffeine cache tuned for broker schema validation.

BrokerAssociatedNameStrategy() - Constructor for class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

C

cachedSchemaLookup() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

The cache-only lookup backing the async path, or null when SchemaValidationContext.schemaRegistry() cannot serve one.

CachedSchemaLookup - Interface in io.confluent.kafka.schemaregistry.validator.core

Non-blocking, cache-only lookups used by the async validation path.

clientErrorsSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

close() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

close() - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

configure(Map) - Method in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

configure(Map) - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

connectionErrorsSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

contextName() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Schema Registry context to qualify subjects with, or null/default for none.

contextName() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

D

DEFAULT_BEARER_AUTH_SCOPE_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

DEFAULT_BEARER_AUTH_SUB_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

DEFAULT_CONTEXT_NAME - Static variable in class io.confluent.kafka.schemaregistry.validator.core.SubjectNames

Mirrors LogConfig.DEFAULT_CONTEXT_NAME_SCHEMA_VALIDATION, duplicated rather than referenced so this package does not depend on the storage module.

deleteSchemaVersion(String, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

deleteSchemaVersion(Map, String, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

deleteSubject(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

deleteSubject(Map, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

F

FAILURE_BACKOFF_SECS - Static variable in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

After exhausting retries, how long (seconds) to short-circuit further lookups for the same key and rethrow the cached failure without calling Schema Registry.

G

getAllSubjects() - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getAllSubjectsById(int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getAllVersions(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getAssociationCacheTtl() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getAssociationsByResourceName(String, String, String, List, String, int, int) - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

getAsyncSchemaValidationEnabled() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getBadIdCacheTtl() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getBadSchemaCacheTtl() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getById(int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getByID(int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

Deprecated.

getBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getBySubjectAndID(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

Deprecated.

getByVersion(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

getCompatibility(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getEnableGuidSchemaValidation() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getGuid(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getGuid(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getGuid(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getGuidIfCached(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

The cached guid registered for schema under subject; null on a genuine cache miss (caller returns RETRY); CachedSchemaLookup.GUID_ABSENT when the schema is known not to be registered (caller rejects).

getGuidIfCached(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getId(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getId(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getId(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getId(String, Schema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getIdIfCached(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

The cached id registered for schema under subject; null on a genuine cache miss (caller returns RETRY); CachedSchemaLookup.ID_ABSENT when the schema is known not to be registered (caller rejects).

getIdIfCached(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getIdWithResponse(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

getLatestSchemaMetadata(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getMaxCacheSize() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getMaxIdQueryRange() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getMaxRetries() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getMode() - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getMode(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getRetriesWaitMs() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getSamplesPerMin() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getSchemaByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getSchemaByGuidIfCached(String, String, SubjectNameStrategy, String, boolean, String) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

The cached schema for guid, or null on a cache miss.

getSchemaByGuidIfCached(String, String, SubjectNameStrategy, String, boolean, String) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getSchemaById(int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getSchemaBySubjectAndIdIfCached(String, int, SubjectNameStrategy, String, boolean, String) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

The cached schema for subject and id, or null on a cache miss.

getSchemaBySubjectAndIdIfCached(String, int, SubjectNameStrategy, String, boolean, String) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

getSchemaMetadata(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getSchemaRegistryUrls() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getSchemaValidationCacheTtl() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getSchemaValidationContextName() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

getValue() - Method in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

getVersion(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

getVersion(String, Schema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

GUID_ABSENT - Static variable in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

Returned by CachedSchemaLookup.getGuidIfCached(String, ParsedSchema) when the schema is known not to be registered.

GUID_SCHEMA_VALIDATION_FEATURE_ENABLED_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

GUID_SCHEMA_VALIDATION_FEATURE_ENABLED_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

H

HEADER - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

Schema ID (GUID) was found in the record header.

headerRecordSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

headerRejectedSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

headerRetrySensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

I

ID_ABSENT - Static variable in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

Returned by CachedSchemaLookup.getIdIfCached(String, ParsedSchema) when the schema is known not to be registered.

INSTANCE - Static variable in class io.confluent.kafka.schemaregistry.validator.core.SchemaIdValidationCore

Shared instance.

io.confluent.kafka.schemaregistry.validator - package io.confluent.kafka.schemaregistry.validator

io.confluent.kafka.schemaregistry.validator.core - package io.confluent.kafka.schemaregistry.validator.core

isGuidBanned(String) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

True when guid is known not to exist, so the record can be rejected without consulting Schema Registry.

isGuidBanned(String) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

isIdBanned(String, int) - Method in interface io.confluent.kafka.schemaregistry.validator.core.CachedSchemaLookup

True when id is known not to exist for subject, so the record can be rejected without consulting Schema Registry.

isIdBanned(String, int) - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

K

KEY_SCHEMA_VALIDATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

KEY_SCHEMA_VALIDATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

KEY_SUBJECT_NAME_STRATEGY_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

KEY_SUBJECT_NAME_STRATEGY_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

KEY_SUBJECT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

keySubjectNameStrategy() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

L

logger() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Logger to attribute validation failures to.

logger() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

loggingSampler() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Rate limiter for per-record failure logging, so one bad producer cannot flood the log.

loggingSampler() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

LoggingSamplers - Class in io.confluent.kafka.schemaregistry.validator.core

Factories for the log samplers used to rate-limit per-record validation logging.

LruSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.validator

An implementation of SchemaRegistryClient that only supports SchemaRegistryClient.getSchemaBySubjectAndId(String, int) and SchemaRegistryClient.getId(String, ParsedSchema).

LruSchemaRegistryClient(RestService, int, int, int, Map, Map, Ticker, int, long, long, long) - Constructor for class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

LruSchemaRegistryClient(List, int, int, int, Map, Map, int, long, long, long) - Constructor for class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

LruSchemaRegistryClient(List, int, int, int, Map, Map, Ticker, int, long, long, long) - Constructor for class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

M

MAX_CACHE_SIZE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MAX_CACHE_SIZE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MAX_CACHE_SIZE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MAX_RETRIES - Static variable in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

Max retries on a transient (IOException / 5xx) association lookup failure.

MAX_RETRIES_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MAX_RETRIES_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MAX_RETRIES_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

maybeAddContextName(String, String) - Static method in class io.confluent.kafka.schemaregistry.validator.core.SubjectNames

Qualify subject with contextName unless the context is absent or is the default context, in which case the subject is returned unchanged.

metrics() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Where validation metrics are recorded.

metrics() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

MISSING_ID_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_ID_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_ID_CACHE_TTL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_ID_QUERY_RANGE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_ID_QUERY_RANGE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_ID_QUERY_RANGE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_SCHEMA_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_SCHEMA_CACHE_TTL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

MISSING_SUBJECT_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

N

NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

No valid schema ID was found in either header or payload.

noneRecordSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

noneRejectedSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

noneRetrySensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

NOOP - Static variable in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

Discards everything.

O

onAppend(TopicPartition, Record) - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

P

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

parseSchema(String, String, List) - Method in class io.confluent.kafka.schemaregistry.validator.RestBackedSchemaRegistryClient

PAYLOAD - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

Schema ID (integer) was found in the message payload.

payloadRecordSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

payloadRejectedSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

payloadRetrySensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

perMinute(long) - Static method in class io.confluent.kafka.schemaregistry.validator.core.LoggingSamplers

A negative samplesPerMin suppresses logging entirely, zero logs everything, and a positive value caps logging at roughly that many samples per minute.

R

recordClientError() - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordClientError() - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A 4xx from Schema Registry.

recordConnectionError() - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordConnectionError() - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A failure reaching Schema Registry at all (connection level).

recordRecord(SchemaIdType) - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordRecord(SchemaIdType) - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A validated record, tagged by where its schema id was found.

recordRejected(SchemaIdType) - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordRejected(SchemaIdType) - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A record rejected by validation.

recordRetry(SchemaIdType) - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordRetry(SchemaIdType) - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A record whose validation could not complete from cache and will be retried.

RecordSchemaValidator - Class in io.confluent.kafka.schemaregistry.validator

A RecordInterceptor that performs schema validation.

RecordSchemaValidator() - Constructor for class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

RecordSchemaValidator(SchemaRegistryClient, Logger) - Constructor for class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

RecordSchemaValidatorConfig - Class in io.confluent.kafka.schemaregistry.validator

RecordSchemaValidatorConfig(Map) - Constructor for class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

RecordSchemaValidatorConfig(ConfigDef, Map) - Constructor for class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

recordServerError() - Method in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

recordServerError() - Method in interface io.confluent.kafka.schemaregistry.validator.core.ValidationMetricsRecorder

A 5xx from Schema Registry.

register(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

register(String, ParsedSchema, int, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

register(String, Schema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

register(String, Schema, int, int) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

REJECT - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.ValidationDecision

The record failed validation and must not be appended.

reset() - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

reset() - Method in class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

RestBackedSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.validator

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.

RETRIES_WAIT_MS - Static variable in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

Wait, in milliseconds, between transient retries.

RETRIES_WAIT_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

RETRIES_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

RETRIES_WAIT_MS_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

RETRY - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.core.ValidationDecision

Validation could not be completed from cache.

S

SAMPLES_PER_MIN_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SAMPLES_PER_MIN_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_REGISTRY_URL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_REGISTRY_URL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_VALIDATION_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_VALIDATION_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_VALIDATION_CACHE_TTL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_VALIDATION_CONTEXT_NAME_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SCHEMA_VALIDATION_CONTEXT_NAME_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SchemaIdType - Enum Class in io.confluent.kafka.schemaregistry.validator.core

Represents how the schema ID was resolved during validation.

SchemaIdValidationCore - Class in io.confluent.kafka.schemaregistry.validator.core

Schema ID validation, shared by every caller that needs it.

schemaRegistry() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

The Schema Registry to validate against.

schemaRegistry() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

SchemaValidationContext - Interface in io.confluent.kafka.schemaregistry.validator.core

Everything SchemaIdValidationCore needs to validate a record: which Schema Registry to ask, how to derive the subject, and what to validate.

SensorValidationMetricsRecorder - Class in io.confluent.kafka.schemaregistry.validator.core

Records validation metrics into Kafka Sensors.

SensorValidationMetricsRecorder() - Constructor for class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

serverErrorsSensor - Variable in class io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

setKafkaClusterId(String) - Method in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

setMode(String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

setMode(String, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

setSchemaRegistryClient(SchemaRegistryClient) - Method in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

SSL_KEY_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEY_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_LOCATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_LOCATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_TYPE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_KEYSTORE_TYPE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_PROTOCOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_PROTOCOL_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_LOCATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_LOCATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_TYPE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

SSL_TRUSTSTORE_TYPE_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

subjectName(String, boolean, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.BrokerAssociatedNameStrategy

SubjectNames - Class in io.confluent.kafka.schemaregistry.validator.core

Subject-name helpers shared by the schema validation core and the Schema Registry client wrappers.

subjectNameStrategy(boolean) - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

The subject-name strategy for the key or the value.

subjectNameStrategy(boolean) - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

T

testCompatibility(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

testCompatibility(String, Schema) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

U

updateCompatibility(String, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

USER_INFO_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

USER_INFO_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

USER_INFO_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

V

validateKey() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

validateKey() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

validateKey() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

validateRecord(SchemaValidationContext, String, ReadableBuf, ReadableBuf, Header[]) - Method in class io.confluent.kafka.schemaregistry.validator.core.SchemaIdValidationCore

Validate one record and record the corresponding metrics on ctx.

validateValue() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

validateValue() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

validateValue() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

validateWithGuid() - Method in interface io.confluent.kafka.schemaregistry.validator.core.SchemaValidationContext

Whether to look for a schema guid in the record headers before falling back to the payload.

validateWithGuid() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

ValidationDecision - Enum Class in io.confluent.kafka.schemaregistry.validator.core

Outcome of validating one record.

ValidationMetricsRecorder - Interface in io.confluent.kafka.schemaregistry.validator.core

Sink for schema-validation metrics.

VALUE_SCHEMA_VALIDATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

VALUE_SCHEMA_VALIDATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

VALUE_SUBJECT_NAME_STRATEGY_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

VALUE_SUBJECT_NAME_STRATEGY_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

VALUE_SUBJECT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.validator.core.ValidationDecision

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafka.schemaregistry.validator.core.SchemaIdType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.validator.core.ValidationDecision

Returns an array containing the constants of this enum class, in the order they are declared.

valueSubjectNameStrategy() - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

A B C D F G H I K L M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values