Index

A B C D 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

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

C

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

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

configure(Map) - 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

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

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

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

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

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

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

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

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

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

getSchemaRegistryUrls() - 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.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_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.SchemaIdType

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

I

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

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

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) - Constructor for class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

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

LruSchemaRegistryClient(List, int, int, int, Map, Map, Ticker, int, 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_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

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

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

O

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

P

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

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

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

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

R

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

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

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

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

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

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

Represents how the schema ID was resolved during validation.

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

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

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

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 class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig

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

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

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

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

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 G H I K L M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values