Package io.confluent.kafka.serializers.json

Class KafkaJsonSchemaDeserializerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

public class KafkaJsonSchemaDeserializerConfig
extends AbstractKafkaSchemaSerDeConfig

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AbstractKafkaSchemaSerDeConfig.ValidationRulesExecution

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FAIL_INVALID_SCHEMA
static final boolean	FAIL_INVALID_SCHEMA_DEFAULT
static final String	FAIL_INVALID_SCHEMA_DOC
static final String	FAIL_UNKNOWN_PROPERTIES
static final boolean	FAIL_UNKNOWN_PROPERTIES_DEFAULT
static final String	FAIL_UNKNOWN_PROPERTIES_DOC
static final String	JSON_KEY_TYPE
static final String	JSON_KEY_TYPE_DEFAULT
static final String	JSON_KEY_TYPE_DOC
static final String	JSON_VALUE_TYPE
static final String	JSON_VALUE_TYPE_DEFAULT
static final String	JSON_VALUE_TYPE_DOC
static final String	TYPE_ALLOWED_PACKAGES
static final String	TYPE_ALLOWED_PACKAGES_DEFAULT
static final String	TYPE_ALLOWED_PACKAGES_DOC
static final String	TYPE_PROPERTY
static final String	TYPE_PROPERTY_DEFAULT
static final String	TYPE_PROPERTY_DOC
static final String	VALIDATE_BEFORE_DOMAIN_RULES
static final boolean	VALIDATE_BEFORE_DOMAIN_RULES_DEFAULT
static final String	VALIDATE_BEFORE_DOMAIN_RULES_DOC

Fields inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AUTO_REGISTER_SCHEMAS, AUTO_REGISTER_SCHEMAS_DEFAULT, AUTO_REGISTER_SCHEMAS_DOC, BASIC_AUTH_CREDENTIALS_SOURCE, BASIC_AUTH_CREDENTIALS_SOURCE_DEFAULT, BASIC_AUTH_CREDENTIALS_SOURCE_DOC, BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS, BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT, BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DOC, BEARER_AUTH_CLIENT_ID, BEARER_AUTH_CLIENT_ID_DOC, BEARER_AUTH_CLIENT_SECRET, BEARER_AUTH_CLIENT_SECRET_DOC, BEARER_AUTH_CREDENTIALS_SOURCE, BEARER_AUTH_CREDENTIALS_SOURCE_DEFAULT, BEARER_AUTH_CREDENTIALS_SOURCE_DOC, BEARER_AUTH_CUSTOM_PROVIDER_CLASS, BEARER_AUTH_CUSTOM_PROVIDER_CLASS_D0C, BEARER_AUTH_IDENTITY_POOL_ID, BEARER_AUTH_IDENTITY_POOL_ID_DOC, BEARER_AUTH_ISSUER_ENDPOINT_URL, BEARER_AUTH_ISSUER_ENDPOINT_URL_DOC, BEARER_AUTH_LOGICAL_CLUSTER, BEARER_AUTH_LOGICAL_CLUSTER_DOC, BEARER_AUTH_SCOPE, BEARER_AUTH_SCOPE_CLAIM_NAME, BEARER_AUTH_SCOPE_CLAIM_NAME_DOC, BEARER_AUTH_SCOPE_DOC, BEARER_AUTH_SUB_CLAIM_NAME, BEARER_AUTH_SUB_CLAIM_NAME_DOC, BEARER_AUTH_TOKEN_CONFIG, BEARER_AUTH_TOKEN_DEFAULT, BEARER_AUTH_TOKEN_DOC, CONTEXT_NAME_STRATEGY, CONTEXT_NAME_STRATEGY_DEFAULT, CONTEXT_NAME_STRATEGY_DOC, DEFAULT_BEARER_AUTH_SCOPE_CLAIM_NAME, DEFAULT_BEARER_AUTH_SUB_CLAIM_NAME, EXECUTION_ENVIRONMENT, EXECUTION_ENVIRONMENT_DOCS, HTTP_CONNECT_TIMEOUT_MS, HTTP_CONNECT_TIMEOUT_MS_DEFAULT, HTTP_CONNECT_TIMEOUT_MS_DOC, HTTP_READ_TIMEOUT_MS, HTTP_READ_TIMEOUT_MS_DEFAULT, HTTP_READ_TIMEOUT_MS_DOC, ID_COMPATIBILITY_STRICT, ID_COMPATIBILITY_STRICT_DEFAULT, ID_COMPATIBILITY_STRICT_DOC, KEY_SCHEMA_ID_DESERIALIZER, KEY_SCHEMA_ID_DESERIALIZER_DEFAULT, KEY_SCHEMA_ID_DESERIALIZER_DOC, KEY_SCHEMA_ID_SERIALIZER, KEY_SCHEMA_ID_SERIALIZER_DEFAULT, KEY_SCHEMA_ID_SERIALIZER_DOC, KEY_SUBJECT_NAME_STRATEGY, KEY_SUBJECT_NAME_STRATEGY_DEFAULT, KEY_SUBJECT_NAME_STRATEGY_DOC, LATEST_CACHE_SIZE, LATEST_CACHE_SIZE_DEFAULT, LATEST_CACHE_SIZE_DOC, LATEST_CACHE_TTL, LATEST_CACHE_TTL_DEFAULT, LATEST_CACHE_TTL_DOC, LATEST_COMPATIBILITY_STRICT, LATEST_COMPATIBILITY_STRICT_DEFAULT, LATEST_COMPATIBILITY_STRICT_DOC, MAX_RETRIES_CONFIG, MAX_RETRIES_DEFAULT, MAX_RETRIES_DOC, MAX_SCHEMAS_PER_SUBJECT_CONFIG, MAX_SCHEMAS_PER_SUBJECT_DEFAULT, MAX_SCHEMAS_PER_SUBJECT_DOC, NORMALIZE_SCHEMAS, NORMALIZE_SCHEMAS_DEFAULT, NORMALIZE_SCHEMAS_DOC, PROPAGATE_SCHEMA_TAGS, PROPAGATE_SCHEMA_TAGS_DEFAULT, PROPAGATE_SCHEMA_TAGS_DOC, PROXY_HOST, PROXY_HOST_DEFAULT, PROXY_HOST_DOC, PROXY_PORT, PROXY_PORT_DEFAULT, PROXY_PORT_DOC, REQUEST_HEADER_PREFIX, RETRIES_MAX_WAIT_MS_CONFIG, RETRIES_MAX_WAIT_MS_DEFAULT, RETRIES_MAX_WAIT_MS_DOC, RETRIES_WAIT_MS_CONFIG, RETRIES_WAIT_MS_DEFAULT, RETRIES_WAIT_MS_DOC, RULE_ACTIONS, RULE_ACTIONS_DOCS, RULE_EXECUTORS, RULE_EXECUTORS_DOCS, RULE_METRICS_ENABLE, RULE_METRICS_ENABLE_DEFAULT, RULE_METRICS_ENABLE_DOCS, RULE_SERVICE_LOADER_ENABLE, RULE_SERVICE_LOADER_ENABLE_DOCS, SCHEMA_FORMAT, SCHEMA_FORMAT_DOC, SCHEMA_REFLECTION_CONFIG, SCHEMA_REFLECTION_DEFAULT, SCHEMA_REFLECTION_DOC, SCHEMA_REGISTRY_URL_CONFIG, SCHEMA_REGISTRY_URL_DOC, SCHEMA_REGISTRY_URL_RANDOMIZE_CONFIG, SCHEMA_REGISTRY_URL_RANDOMIZE_DEFAULT, SCHEMA_REGISTRY_URL_RANDOMIZE_DOC, SCHEMA_REGISTRY_USER_INFO_CONFIG, SCHEMA_REGISTRY_USER_INFO_DEFAULT, SCHEMA_REGISTRY_USER_INFO_DOC, USE_LATEST_VERSION, USE_LATEST_VERSION_DEFAULT, USE_LATEST_VERSION_DOC, USE_LATEST_WITH_METADATA, USE_LATEST_WITH_METADATA_DOC, USE_SCHEMA_GUID, USE_SCHEMA_GUID_DOC, USE_SCHEMA_ID, USE_SCHEMA_ID_DEFAULT, USE_SCHEMA_ID_DOC, USER_INFO_CONFIG, USER_INFO_DEFAULT, VALIDATION_RULES_EXECUTOR_CLASS, VALIDATION_RULES_EXECUTOR_CLASS_DEFAULT, VALIDATION_RULES_EXECUTOR_CLASS_DOCS, VALIDATION_RULES_FAIL_FAST, VALIDATION_RULES_FAIL_FAST_DEFAULT, VALIDATION_RULES_FAIL_FAST_DOCS, VALUE_SCHEMA_ID_DESERIALIZER, VALUE_SCHEMA_ID_DESERIALIZER_DEFAULT, VALUE_SCHEMA_ID_DESERIALIZER_DOC, VALUE_SCHEMA_ID_SERIALIZER, VALUE_SCHEMA_ID_SERIALIZER_DEFAULT, VALUE_SCHEMA_ID_SERIALIZER_DOC, VALUE_SUBJECT_NAME_STRATEGY, VALUE_SUBJECT_NAME_STRATEGY_DEFAULT, VALUE_SUBJECT_NAME_STRATEGY_DOC

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
KafkaJsonSchemaDeserializerConfig(Map<?,?> props)

Method Summary

Methods inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

autoRegisterSchema, baseConfigDef, basicAuthUserInfo, contextNameStrategy, enableRuleMetrics, enableRuleServiceLoader, getExecutionEnvironment, getIdCompatibilityStrict, getLatestCacheSize, getLatestCacheTtl, getLatestCompatibilityStrict, getLatestWithMetadataSpec, getMaxSchemasPerSubject, getSchemaFormat, getSchemaRegistryUrls, getValidationRulesFailFast, keySchemaIdDeserializer, keySchemaIdSerializer, keySubjectNameStrategy, normalizeSchema, propagateSchemaTags, requestHeaders, useLatestVersion, useSchemaGuid, useSchemaId, useSchemaReflection, valueSchemaIdDeserializer, valueSchemaIdSerializer, valueSubjectNameStrategy

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, preProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

FAIL_UNKNOWN_PROPERTIES

public static final String FAIL_UNKNOWN_PROPERTIES

See Also:

• Constant Field Values

FAIL_UNKNOWN_PROPERTIES_DEFAULT

public static final boolean FAIL_UNKNOWN_PROPERTIES_DEFAULT

See Also:

• Constant Field Values

FAIL_UNKNOWN_PROPERTIES_DOC

public static final String FAIL_UNKNOWN_PROPERTIES_DOC

See Also:

• Constant Field Values

FAIL_INVALID_SCHEMA

public static final String FAIL_INVALID_SCHEMA

See Also:

• Constant Field Values

FAIL_INVALID_SCHEMA_DEFAULT

public static final boolean FAIL_INVALID_SCHEMA_DEFAULT

See Also:

• Constant Field Values

FAIL_INVALID_SCHEMA_DOC

public static final String FAIL_INVALID_SCHEMA_DOC

See Also:

• Constant Field Values

VALIDATE_BEFORE_DOMAIN_RULES

public static final String VALIDATE_BEFORE_DOMAIN_RULES

See Also:

• Constant Field Values

VALIDATE_BEFORE_DOMAIN_RULES_DEFAULT

public static final boolean VALIDATE_BEFORE_DOMAIN_RULES_DEFAULT

See Also:

• Constant Field Values

VALIDATE_BEFORE_DOMAIN_RULES_DOC

public static final String VALIDATE_BEFORE_DOMAIN_RULES_DOC

See Also:

• Constant Field Values

JSON_KEY_TYPE

public static final String JSON_KEY_TYPE

See Also:

• Constant Field Values

JSON_KEY_TYPE_DEFAULT

public static final String JSON_KEY_TYPE_DEFAULT

JSON_KEY_TYPE_DOC

public static final String JSON_KEY_TYPE_DOC

See Also:

• Constant Field Values

JSON_VALUE_TYPE

public static final String JSON_VALUE_TYPE

See Also:

• Constant Field Values

JSON_VALUE_TYPE_DEFAULT

public static final String JSON_VALUE_TYPE_DEFAULT

JSON_VALUE_TYPE_DOC

public static final String JSON_VALUE_TYPE_DOC

See Also:

• Constant Field Values

TYPE_PROPERTY

public static final String TYPE_PROPERTY

See Also:

• Constant Field Values

TYPE_PROPERTY_DEFAULT

public static final String TYPE_PROPERTY_DEFAULT

See Also:

• Constant Field Values

TYPE_PROPERTY_DOC

public static final String TYPE_PROPERTY_DOC

See Also:

• Constant Field Values

TYPE_ALLOWED_PACKAGES

public static final String TYPE_ALLOWED_PACKAGES

See Also:

• Constant Field Values

TYPE_ALLOWED_PACKAGES_DEFAULT

public static final String TYPE_ALLOWED_PACKAGES_DEFAULT

See Also:

• Constant Field Values

TYPE_ALLOWED_PACKAGES_DOC

public static final String TYPE_ALLOWED_PACKAGES_DOC

See Also:

• Constant Field Values

Constructor Details

KafkaJsonSchemaDeserializerConfig

public KafkaJsonSchemaDeserializerConfig(Map<?,?> props)