Class RecordSchemaValidatorConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig
public class RecordSchemaValidatorConfig
extends org.apache.kafka.common.config.AbstractConfig
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Shortstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final longstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final longstatic final Stringstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final StringFields inherited from class org.apache.kafka.common.config.AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC -
Constructor Summary
ConstructorsConstructorDescriptionRecordSchemaValidatorConfig(Map<?, ?> props) RecordSchemaValidatorConfig(org.apache.kafka.common.config.ConfigDef configDef, Map<?, ?> props) -
Method Summary
Modifier and TypeMethodDescriptionstatic org.apache.kafka.common.config.ConfigDeflonglongintintintintlongio.confluent.kafka.serializers.subject.strategy.SubjectNameStrategybooleanbooleanio.confluent.kafka.serializers.subject.strategy.SubjectNameStrategyMethods inherited from class org.apache.kafka.common.config.AbstractConfig
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
-
Field Details
-
SCHEMA_REGISTRY_URL_CONFIG
- See Also:
-
SCHEMA_REGISTRY_URL_DOC
- See Also:
-
KEY_SCHEMA_VALIDATION_CONFIG
- See Also:
-
KEY_SCHEMA_VALIDATION_DOC
- See Also:
-
VALUE_SCHEMA_VALIDATION_CONFIG
- See Also:
-
VALUE_SCHEMA_VALIDATION_DOC
- See Also:
-
SCHEMA_VALIDATION_CONTEXT_NAME_CONFIG
- See Also:
-
SCHEMA_VALIDATION_CONTEXT_NAME_DOC
- See Also:
-
KEY_SUBJECT_NAME_STRATEGY_CONFIG
- See Also:
-
KEY_SUBJECT_NAME_STRATEGY_DEFAULT
-
KEY_SUBJECT_NAME_STRATEGY_DOC
- See Also:
-
VALUE_SUBJECT_NAME_STRATEGY_CONFIG
- See Also:
-
VALUE_SUBJECT_NAME_STRATEGY_DEFAULT
-
VALUE_SUBJECT_NAME_STRATEGY_DOC
- See Also:
-
MAX_CACHE_SIZE_CONFIG
- See Also:
-
MAX_CACHE_SIZE_DOC
- See Also:
-
MAX_CACHE_SIZE_DEFAULT
public static final int MAX_CACHE_SIZE_DEFAULT- See Also:
-
MAX_RETRIES_CONFIG
- See Also:
-
MAX_RETRIES_DOC
- See Also:
-
MAX_RETRIES_DEFAULT
public static final int MAX_RETRIES_DEFAULT- See Also:
-
RETRIES_WAIT_MS_CONFIG
- See Also:
-
RETRIES_WAIT_MS_DOC
- See Also:
-
RETRIES_WAIT_MS_DEFAULT
public static final int RETRIES_WAIT_MS_DEFAULT- See Also:
-
MISSING_ID_QUERY_RANGE_CONFIG
- See Also:
-
MISSING_ID_QUERY_RANGE_DOC
- See Also:
-
MISSING_ID_QUERY_RANGE_DEFAULT
public static final int MISSING_ID_QUERY_RANGE_DEFAULT- See Also:
-
MISSING_ID_CACHE_TTL_CONFIG
- See Also:
-
MISSING_ID_CACHE_TTL_DOC
- See Also:
-
MISSING_ID_CACHE_TTL_DEFAULT
public static final long MISSING_ID_CACHE_TTL_DEFAULT- See Also:
-
MISSING_SUBJECT_CACHE_TTL_CONFIG
- See Also:
-
MISSING_SCHEMA_CACHE_TTL_DOC
- See Also:
-
MISSING_SCHEMA_CACHE_TTL_DEFAULT
public static final long MISSING_SCHEMA_CACHE_TTL_DEFAULT- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE_CONFIG
- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE_DOC
- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE_DEFAULT
-
USER_INFO_CONFIG
- See Also:
-
USER_INFO_DOC
- See Also:
-
USER_INFO_DEFAULT
-
BEARER_AUTH_CREDENTIALS_SOURCE_CONFIG
- See Also:
-
BEARER_AUTH_CREDENTIALS_SOURCE_DOC
- See Also:
-
BEARER_AUTH_CREDENTIALS_SOURCE_DEFAULT
-
BEARER_AUTH_TOKEN_CONFIG
- See Also:
-
BEARER_AUTH_TOKEN_DOC
- See Also:
-
BEARER_AUTH_TOKEN_DEFAULT
-
BEARER_AUTH_ISSUER_ENDPOINT_URL
- See Also:
-
BEARER_AUTH_ISSUER_ENDPOINT_URL_DOC
- See Also:
-
BEARER_AUTH_CLIENT_ID
- See Also:
-
BEARER_AUTH_CLIENT_ID_DOC
- See Also:
-
BEARER_AUTH_CLIENT_SECRET
- See Also:
-
BEARER_AUTH_CLIENT_SECRET_DOC
- See Also:
-
BEARER_AUTH_SCOPE
- See Also:
-
BEARER_AUTH_SCOPE_DOC
- See Also:
-
BEARER_AUTH_SCOPE_CLAIM_NAME
- See Also:
-
BEARER_AUTH_SCOPE_CLAIM_NAME_DOC
- See Also:
-
DEFAULT_BEARER_AUTH_SCOPE_CLAIM_NAME
- See Also:
-
BEARER_AUTH_SUB_CLAIM_NAME
- See Also:
-
BEARER_AUTH_SUB_CLAIM_NAME_DOC
- See Also:
-
DEFAULT_BEARER_AUTH_SUB_CLAIM_NAME
- See Also:
-
BEARER_AUTH_LOGICAL_CLUSTER
- See Also:
-
BEARER_AUTH_LOGICAL_CLUSTER_DOC
- See Also:
-
BEARER_AUTH_IDENTITY_POOL_ID
- See Also:
-
BEARER_AUTH_IDENTITY_POOL_ID_DOC
- See Also:
-
BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS
- See Also:
-
BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT
-
BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DOC
- See Also:
-
SSL_PROTOCOL_CONFIG
- See Also:
-
SSL_PROTOCOL_DOC
- See Also:
-
SSL_KEYSTORE_LOCATION_CONFIG
- See Also:
-
SSL_KEYSTORE_LOCATION_DOC
- See Also:
-
SSL_KEYSTORE_TYPE_CONFIG
- See Also:
-
SSL_KEYSTORE_TYPE_DOC
- See Also:
-
SSL_KEYSTORE_PASSWORD_CONFIG
- See Also:
-
SSL_KEYSTORE_PASSWORD_DOC
- See Also:
-
SSL_KEY_PASSWORD_CONFIG
- See Also:
-
SSL_KEY_PASSWORD_DOC
- See Also:
-
SSL_TRUSTSTORE_TYPE_CONFIG
- See Also:
-
SSL_TRUSTSTORE_TYPE_DOC
- See Also:
-
SSL_TRUSTSTORE_LOCATION_CONFIG
- See Also:
-
SSL_TRUSTSTORE_LOCATION_DOC
- See Also:
-
SSL_TRUSTSTORE_PASSWORD_CONFIG
- See Also:
-
SSL_TRUSTSTORE_PASSWORD_DOC
- See Also:
-
SAMPLES_PER_MIN_CONFIG
- See Also:
-
SAMPLES_PER_MIN_DOC
- See Also:
-
GUID_SCHEMA_VALIDATION_FEATURE_ENABLED_CONFIG
- See Also:
-
GUID_SCHEMA_VALIDATION_FEATURE_ENABLED_DOC
- See Also:
-
-
Constructor Details
-
RecordSchemaValidatorConfig
-
RecordSchemaValidatorConfig
public RecordSchemaValidatorConfig(org.apache.kafka.common.config.ConfigDef configDef, Map<?, ?> props)
-
-
Method Details
-
baseRecordSchemaValidatorConfigDef
public static org.apache.kafka.common.config.ConfigDef baseRecordSchemaValidatorConfigDef() -
getSamplesPerMin
public long getSamplesPerMin() -
getSchemaRegistryUrls
-
keySubjectNameStrategy
public io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy keySubjectNameStrategy() -
valueSubjectNameStrategy
public io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy valueSubjectNameStrategy() -
validateKey
public boolean validateKey() -
validateValue
public boolean validateValue() -
getSchemaValidationContextName
-
getEnableGuidSchemaValidation
-
getMaxCacheSize
public int getMaxCacheSize() -
getMaxRetries
public int getMaxRetries() -
getRetriesWaitMs
public int getRetriesWaitMs() -
getMaxIdQueryRange
public int getMaxIdQueryRange() -
getBadIdCacheTtl
public long getBadIdCacheTtl() -
getBadSchemaCacheTtl
public long getBadSchemaCacheTtl()
-