Index

A B C D E F G H I K L M 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

COMMUNITY - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicensePrivilegeLevel

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.validator.RecordSchemaValidator

CP - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.DeploymentScope

CP_FOR_CC - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.DeploymentScope

CP_FOR_CC - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicensePrivilegeLevel

CSFLE - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

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>, 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, String>, String) - Method in class io.confluent.kafka.schemaregistry.validator.AbstractSchemaRegistryClient

DeploymentScope - Enum Class in io.confluent.kafka.schemaregistry.validator.licensing.entities

Enum representing the deployment scope of a license for Schema Registry validation purposes.

deserializeDeploymentAttributes(Set<String>) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.LicenseDeserializer

Parses LocalV1License entities from attribute strings.

DestinationLicenseValidator - Class in io.confluent.kafka.schemaregistry.validator.licensing

Validator for destination Schema Registry license enforcement.

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

DestinationLicenseValidator.ValidationResult - Class in io.confluent.kafka.schemaregistry.validator.licensing

Result of destination license validation.

E

ENTERPRISE - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicensePrivilegeLevel

ENTERPRISE - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

equals(Object) - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

equals(Object) - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

F

FREE_TIER - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

fromAttributeString(String) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

Parses a LocalV1License from an attribute string.

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

Deserializes a LocalV1License from JSON.

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

getDeploymentScope() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

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

getErrorMessage() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator.ValidationResult

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

getKey() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

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

getLicenses() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

getLicenses(SchemaRegistryClient) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.MetadataUtils

Get license information from a SchemaRegistryClient.

getLicenseType() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

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

getMetadata(SchemaRegistryClient) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.MetadataUtils

Get metadata from a SchemaRegistryClient.

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

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

getPrivilegeLevel() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator.ValidationResult

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

getVersion() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

getVersion(SchemaRegistryClient) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.MetadataUtils

Get version string from a SchemaRegistryClient.

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

hashCode() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

hashCode() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

I

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

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

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

isV1LicenseAttribute(String) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.LicenseDeserializer

Checks if an attribute string is a V1License format.

isValid() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator.ValidationResult

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

LicenseDeserializer - Class in io.confluent.kafka.schemaregistry.validator.licensing

Utility class for serializing and parsing license attributes.

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

LicensePrivilegeLevel - Enum Class in io.confluent.kafka.schemaregistry.validator.licensing.entities

Enum representing the hierarchy of license privilege levels for Schema Registry validation.

LicenseType - Enum Class in io.confluent.kafka.schemaregistry.validator.licensing.entities

Enum representing the type of license for Schema Registry validation purposes.

LocalV1License - Class in io.confluent.kafka.schemaregistry.validator.licensing.entities

Version 1 license entity that groups DeploymentScope and LicenseType together to prevent orphaning of related license attributes during serialization.

LocalV1License(LicenseType, DeploymentScope) - Constructor for class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

Creates a LocalV1License with explicit type and scope.

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<String, ?>, Map<String, String>, Ticker, int, long, long) - Constructor for class io.confluent.kafka.schemaregistry.validator.LruSchemaRegistryClient

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

LruSchemaRegistryClient(List<String>, int, int, int, Map<String, ?>, Map<String, String>, 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

MetadataUtils - Class in io.confluent.kafka.schemaregistry.validator.licensing

Utility class for retrieving metadata from SchemaRegistryClient instances.

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

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

O

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

OPEN_SOURCE - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

P

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

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

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

SchemaRegistryMetadata - Class in io.confluent.kafka.schemaregistry.validator.licensing.entities

Container class for Schema Registry metadata including license and version information.

SchemaRegistryMetadata(List<LocalV1License>, String) - Constructor for class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

Creates a new SchemaRegistryMetadata instance.

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

toAttributeString() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

Creates the attribute string in the format: "key:json" This is the format that will be stored in the license attributes.

toJson() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

Serializes this license entity to JSON.

toString() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator.ValidationResult

toString() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.LocalV1License

toString() - Method in class io.confluent.kafka.schemaregistry.validator.licensing.entities.SchemaRegistryMetadata

TRIAL - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

U

UNKNOWN - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.DeploymentScope

UNKNOWN - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicensePrivilegeLevel

UNKNOWN - Enum constant in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

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

validateDestination(SchemaRegistryClient) - Static method in class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator

Validates the destination Schema Registry client against license restrictions.

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

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

ValidationResult(boolean, String, LicensePrivilegeLevel) - Constructor for class io.confluent.kafka.schemaregistry.validator.licensing.DestinationLicenseValidator.ValidationResult

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.licensing.entities.DeploymentScope

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

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicensePrivilegeLevel

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

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.LicenseType

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

values() - Static method in enum class io.confluent.kafka.schemaregistry.validator.licensing.entities.DeploymentScope

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.licensing.entities.LicensePrivilegeLevel

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.licensing.entities.LicenseType

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