Package io.confluent.kafka.serializers.json

Class KafkaJsonSchemaSerializerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

public class KafkaJsonSchemaSerializerConfig
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	DEFAULT_PROPERTY_INCLUSION
static final String	DEFAULT_PROPERTY_INCLUSION_DOC
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_ENVELOPE_DETECTION
static final boolean	JSON_ENVELOPE_DETECTION_DEFAULT
static final String	JSON_ENVELOPE_DETECTION_DOC
static final String	JSON_INDENT_OUTPUT
static final boolean	JSON_INDENT_OUTPUT_DEFAULT
static final String	JSON_INDENT_OUTPUT_DOC
static final String	ONEOF_FOR_NULLABLES
static final boolean	ONEOF_FOR_NULLABLES_DEFAULT
static final String	ONEOF_FOR_NULLABLES_DOC
static final String	SCHEMA_SCAN_PACKAGES
static final String	SCHEMA_SCAN_PACKAGES_DOC
static final String	SCHEMA_SPEC_VERSION
static final String	SCHEMA_SPEC_VERSION_DEFAULT
static final String	SCHEMA_SPEC_VERSION_DOC
static final String	VALIDATE_BEFORE_DOMAIN_RULES
static final boolean	VALIDATE_BEFORE_DOMAIN_RULES_DEFAULT
static final String	VALIDATE_BEFORE_DOMAIN_RULES_DOC
static final String	VALIDATION_RULES_EXECUTION
static final String	VALIDATION_RULES_EXECUTION_DEFAULT
static final String	VALIDATION_RULES_EXECUTION_DOC
static final String	WRITE_DATES_AS_ISO8601
static final boolean	WRITE_DATES_AS_ISO8601_DEFAULT
static final String	WRITE_DATES_AS_ISO8601_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, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
KafkaJsonSchemaSerializerConfig(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

WRITE_DATES_AS_ISO8601

public static final String WRITE_DATES_AS_ISO8601

See Also:

• Constant Field Values

WRITE_DATES_AS_ISO8601_DEFAULT

public static final boolean WRITE_DATES_AS_ISO8601_DEFAULT

See Also:

• Constant Field Values

WRITE_DATES_AS_ISO8601_DOC

public static final String WRITE_DATES_AS_ISO8601_DOC

See Also:

• Constant Field Values

SCHEMA_SPEC_VERSION

public static final String SCHEMA_SPEC_VERSION

See Also:

• Constant Field Values

SCHEMA_SPEC_VERSION_DEFAULT

public static final String SCHEMA_SPEC_VERSION_DEFAULT

SCHEMA_SPEC_VERSION_DOC

public static final String SCHEMA_SPEC_VERSION_DOC

See Also:

• Constant Field Values

SCHEMA_SCAN_PACKAGES

public static final String SCHEMA_SCAN_PACKAGES

See Also:

• Constant Field Values

SCHEMA_SCAN_PACKAGES_DOC

public static final String SCHEMA_SCAN_PACKAGES_DOC

See Also:

• Constant Field Values

JSON_ENVELOPE_DETECTION

public static final String JSON_ENVELOPE_DETECTION

See Also:

• Constant Field Values

JSON_ENVELOPE_DETECTION_DEFAULT

public static final boolean JSON_ENVELOPE_DETECTION_DEFAULT

See Also:

• Constant Field Values

JSON_ENVELOPE_DETECTION_DOC

public static final String JSON_ENVELOPE_DETECTION_DOC

See Also:

• Constant Field Values

ONEOF_FOR_NULLABLES

public static final String ONEOF_FOR_NULLABLES

See Also:

• Constant Field Values

ONEOF_FOR_NULLABLES_DEFAULT

public static final boolean ONEOF_FOR_NULLABLES_DEFAULT

See Also:

• Constant Field Values

ONEOF_FOR_NULLABLES_DOC

public static final String ONEOF_FOR_NULLABLES_DOC

See Also:

• Constant Field Values

DEFAULT_PROPERTY_INCLUSION

public static final String DEFAULT_PROPERTY_INCLUSION

See Also:

• Constant Field Values

DEFAULT_PROPERTY_INCLUSION_DOC

public static final String DEFAULT_PROPERTY_INCLUSION_DOC

See Also:

• Constant Field Values

JSON_INDENT_OUTPUT

public static final String JSON_INDENT_OUTPUT

See Also:

• Constant Field Values

JSON_INDENT_OUTPUT_DEFAULT

public static final boolean JSON_INDENT_OUTPUT_DEFAULT

See Also:

• Constant Field Values

JSON_INDENT_OUTPUT_DOC

public static final String JSON_INDENT_OUTPUT_DOC

See Also:

• Constant Field Values

VALIDATION_RULES_EXECUTION

public static final String VALIDATION_RULES_EXECUTION

See Also:

• Constant Field Values

VALIDATION_RULES_EXECUTION_DEFAULT

public static final String VALIDATION_RULES_EXECUTION_DEFAULT

VALIDATION_RULES_EXECUTION_DOC

public static final String VALIDATION_RULES_EXECUTION_DOC

See Also:

• Constant Field Values

Constructor Details

KafkaJsonSchemaSerializerConfig

public KafkaJsonSchemaSerializerConfig(Map<?,?> props)