Package io.confluent.kafka.serializers
Class AbstractKafkaSchemaSerDeConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig
public class AbstractKafkaSchemaSerDeConfig
extends org.apache.kafka.common.config.AbstractConfig
Base class for configs for serializers and deserializers, defining a few common configs and
defaults.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final booleanstatic final Stringstatic 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 intstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final booleanstatic 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 booleanstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final Stringstatic final booleanstatic final Stringstatic final Stringstatic final booleanstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final intstatic final Stringstatic final StringConfigurations beginning with this prefix can be used to specify headers to include in requests made to Schema Registry.static final Stringstatic final intstatic 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 booleanstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final booleanstatic final Stringstatic final StringDeprecated.static final Stringstatic final Stringstatic final Stringstatic final booleanstatic final Stringstatic 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 StringFields inherited from class org.apache.kafka.common.config.AbstractConfig
AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG -
Constructor Summary
ConstructorsConstructorDescriptionAbstractKafkaSchemaSerDeConfig(org.apache.kafka.common.config.ConfigDef config, Map<?, ?> props) AbstractKafkaSchemaSerDeConfig(org.apache.kafka.common.config.ConfigDef definition, Map<?, ?> originals, boolean doLog) -
Method Summary
Modifier and TypeMethodDescriptionbooleanstatic org.apache.kafka.common.config.ConfigDefbooleanbooleanintintbooleanintbooleanbooleanbooleanintbooleanMethods 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, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
-
Field Details
-
REQUEST_HEADER_PREFIX
Configurations beginning with this prefix can be used to specify headers to include in requests made to Schema Registry. For example, to include anAuthorizationheader with a value ofBearer NjksNDIw, use the following configuration:request.header.Authorization=Bearer NjksNDIw- See Also:
-
SCHEMA_REGISTRY_URL_CONFIG
- See Also:
-
SCHEMA_REGISTRY_URL_DOC
- See Also:
-
SCHEMA_REGISTRY_URL_RANDOMIZE_CONFIG
- See Also:
-
SCHEMA_REGISTRY_URL_RANDOMIZE_DEFAULT
public static final boolean SCHEMA_REGISTRY_URL_RANDOMIZE_DEFAULT- See Also:
-
SCHEMA_REGISTRY_URL_RANDOMIZE_DOC
- See Also:
-
MAX_SCHEMAS_PER_SUBJECT_CONFIG
- See Also:
-
MAX_SCHEMAS_PER_SUBJECT_DEFAULT
public static final int MAX_SCHEMAS_PER_SUBJECT_DEFAULT- See Also:
-
MAX_SCHEMAS_PER_SUBJECT_DOC
- See Also:
-
NORMALIZE_SCHEMAS
- See Also:
-
NORMALIZE_SCHEMAS_DEFAULT
public static final boolean NORMALIZE_SCHEMAS_DEFAULT- See Also:
-
NORMALIZE_SCHEMAS_DOC
- See Also:
-
AUTO_REGISTER_SCHEMAS
- See Also:
-
AUTO_REGISTER_SCHEMAS_DEFAULT
public static final boolean AUTO_REGISTER_SCHEMAS_DEFAULT- See Also:
-
AUTO_REGISTER_SCHEMAS_DOC
- See Also:
-
PROPAGATE_SCHEMA_TAGS
- See Also:
-
PROPAGATE_SCHEMA_TAGS_DEFAULT
public static final boolean PROPAGATE_SCHEMA_TAGS_DEFAULT- See Also:
-
PROPAGATE_SCHEMA_TAGS_DOC
- See Also:
-
USE_SCHEMA_ID
- See Also:
-
USE_SCHEMA_ID_DEFAULT
public static final int USE_SCHEMA_ID_DEFAULT- See Also:
-
USE_SCHEMA_ID_DOC
- See Also:
-
ID_COMPATIBILITY_STRICT
- See Also:
-
ID_COMPATIBILITY_STRICT_DEFAULT
public static final boolean ID_COMPATIBILITY_STRICT_DEFAULT- See Also:
-
ID_COMPATIBILITY_STRICT_DOC
- See Also:
-
USE_LATEST_VERSION
- See Also:
-
USE_LATEST_VERSION_DEFAULT
public static final boolean USE_LATEST_VERSION_DEFAULT- See Also:
-
USE_LATEST_VERSION_DOC
- See Also:
-
USE_LATEST_WITH_METADATA
- See Also:
-
USE_LATEST_WITH_METADATA_DOC
- See Also:
-
LATEST_COMPATIBILITY_STRICT
- See Also:
-
LATEST_COMPATIBILITY_STRICT_DEFAULT
public static final boolean LATEST_COMPATIBILITY_STRICT_DEFAULT- See Also:
-
LATEST_COMPATIBILITY_STRICT_DOC
- See Also:
-
HTTP_CONNECT_TIMEOUT_MS
- See Also:
-
HTTP_CONNECT_TIMEOUT_MS_DEFAULT
public static final int HTTP_CONNECT_TIMEOUT_MS_DEFAULT- See Also:
-
HTTP_CONNECT_TIMEOUT_MS_DOC
- See Also:
-
HTTP_READ_TIMEOUT_MS
- See Also:
-
HTTP_READ_TIMEOUT_MS_DEFAULT
public static final int HTTP_READ_TIMEOUT_MS_DEFAULT- See Also:
-
HTTP_READ_TIMEOUT_MS_DOC
- See Also:
-
MAX_RETRIES_CONFIG
- See Also:
-
MAX_RETRIES_DEFAULT
public static final int MAX_RETRIES_DEFAULT- See Also:
-
MAX_RETRIES_DOC
- See Also:
-
RETRIES_WAIT_MS_CONFIG
- See Also:
-
RETRIES_WAIT_MS_DEFAULT
public static final int RETRIES_WAIT_MS_DEFAULT- See Also:
-
RETRIES_WAIT_MS_DOC
- See Also:
-
RETRIES_MAX_WAIT_MS_CONFIG
- See Also:
-
RETRIES_MAX_WAIT_MS_DEFAULT
public static final int RETRIES_MAX_WAIT_MS_DEFAULT- See Also:
-
RETRIES_MAX_WAIT_MS_DOC
- See Also:
-
LATEST_CACHE_SIZE
- See Also:
-
LATEST_CACHE_SIZE_DEFAULT
public static final int LATEST_CACHE_SIZE_DEFAULT- See Also:
-
LATEST_CACHE_SIZE_DOC
- See Also:
-
LATEST_CACHE_TTL
- See Also:
-
LATEST_CACHE_TTL_DEFAULT
public static final int LATEST_CACHE_TTL_DEFAULT- See Also:
-
LATEST_CACHE_TTL_DOC
- See Also:
-
SCHEMA_FORMAT
- See Also:
-
SCHEMA_FORMAT_DOC
- See Also:
-
RULE_EXECUTORS
- See Also:
-
RULE_EXECUTORS_DOCS
- See Also:
-
RULE_ACTIONS
- See Also:
-
RULE_ACTIONS_DOCS
- See Also:
-
RULE_SERVICE_LOADER_ENABLE
- See Also:
-
RULE_SERVICE_LOADER_ENABLE_DOCS
- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE
- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE_DEFAULT
- See Also:
-
BASIC_AUTH_CREDENTIALS_SOURCE_DOC
- See Also:
-
BEARER_AUTH_CREDENTIALS_SOURCE
- See Also:
-
BEARER_AUTH_CREDENTIALS_SOURCE_DEFAULT
- See Also:
-
BEARER_AUTH_CREDENTIALS_SOURCE_DOC
- See Also:
-
SCHEMA_REGISTRY_USER_INFO_CONFIG
Deprecated.useUSER_INFO_CONFIGinstead- See Also:
-
SCHEMA_REGISTRY_USER_INFO_DEFAULT
- See Also:
-
SCHEMA_REGISTRY_USER_INFO_DOC
- See Also:
-
USER_INFO_CONFIG
- See Also:
-
USER_INFO_DEFAULT
- See Also:
-
BEARER_AUTH_TOKEN_CONFIG
- See Also:
-
BEARER_AUTH_TOKEN_DEFAULT
- See Also:
-
BEARER_AUTH_TOKEN_DOC
- See Also:
-
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:
-
DEFAULT_BEARER_AUTH_SCOPE_CLAIM_NAME
- See Also:
-
BEARER_AUTH_SCOPE_CLAIM_NAME_DOC
- See Also:
-
BEARER_AUTH_SUB_CLAIM_NAME
- See Also:
-
DEFAULT_BEARER_AUTH_SUB_CLAIM_NAME
- See Also:
-
BEARER_AUTH_SUB_CLAIM_NAME_DOC
- 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:
-
BEARER_AUTH_CUSTOM_PROVIDER_CLASS
- See Also:
-
BEARER_AUTH_CUSTOM_PROVIDER_CLASS_D0C
- See Also:
-
CONTEXT_NAME_STRATEGY
- See Also:
-
CONTEXT_NAME_STRATEGY_DEFAULT
-
CONTEXT_NAME_STRATEGY_DOC
- See Also:
-
KEY_SUBJECT_NAME_STRATEGY
- See Also:
-
KEY_SUBJECT_NAME_STRATEGY_DEFAULT
-
KEY_SUBJECT_NAME_STRATEGY_DOC
- See Also:
-
KEY_SCHEMA_ID_SERIALIZER
- See Also:
-
KEY_SCHEMA_ID_SERIALIZER_DEFAULT
-
KEY_SCHEMA_ID_SERIALIZER_DOC
- See Also:
-
KEY_SCHEMA_ID_DESERIALIZER
- See Also:
-
KEY_SCHEMA_ID_DESERIALIZER_DEFAULT
-
KEY_SCHEMA_ID_DESERIALIZER_DOC
- See Also:
-
VALUE_SUBJECT_NAME_STRATEGY
- See Also:
-
VALUE_SUBJECT_NAME_STRATEGY_DEFAULT
-
VALUE_SUBJECT_NAME_STRATEGY_DOC
- See Also:
-
VALUE_SCHEMA_ID_SERIALIZER
- See Also:
-
VALUE_SCHEMA_ID_SERIALIZER_DEFAULT
-
VALUE_SCHEMA_ID_SERIALIZER_DOC
- See Also:
-
VALUE_SCHEMA_ID_DESERIALIZER
- See Also:
-
VALUE_SCHEMA_ID_DESERIALIZER_DEFAULT
-
VALUE_SCHEMA_ID_DESERIALIZER_DOC
- See Also:
-
SCHEMA_REFLECTION_CONFIG
- See Also:
-
SCHEMA_REFLECTION_DEFAULT
public static final boolean SCHEMA_REFLECTION_DEFAULT- See Also:
-
SCHEMA_REFLECTION_DOC
- See Also:
-
PROXY_HOST
- See Also:
-
PROXY_HOST_DEFAULT
- See Also:
-
PROXY_HOST_DOC
- See Also:
-
PROXY_PORT
- See Also:
-
PROXY_PORT_DEFAULT
public static final int PROXY_PORT_DEFAULT- See Also:
-
PROXY_PORT_DOC
- See Also:
-
-
Constructor Details
-
Method Details
-
baseConfigDef
public static org.apache.kafka.common.config.ConfigDef baseConfigDef() -
getMaxSchemasPerSubject
public int getMaxSchemasPerSubject() -
getSchemaRegistryUrls
-
normalizeSchema
public boolean normalizeSchema() -
autoRegisterSchema
public boolean autoRegisterSchema() -
propagateSchemaTags
public boolean propagateSchemaTags() -
useSchemaId
public int useSchemaId() -
getIdCompatibilityStrict
public boolean getIdCompatibilityStrict() -
useLatestVersion
public boolean useLatestVersion() -
getLatestCompatibilityStrict
public boolean getLatestCompatibilityStrict() -
getLatestCacheSize
public int getLatestCacheSize() -
getLatestCacheTtl
public int getLatestCacheTtl() -
getLatestWithMetadataSpec
-
getSchemaFormat
-
enableRuleServiceLoader
public boolean enableRuleServiceLoader() -
contextNameStrategy
-
keySubjectNameStrategy
-
keySchemaIdSerializer
-
keySchemaIdDeserializer
-
valueSubjectNameStrategy
-
valueSchemaIdSerializer
-
valueSchemaIdDeserializer
-
useSchemaReflection
public boolean useSchemaReflection() -
requestHeaders
-
basicAuthUserInfo
-
USER_INFO_CONFIGinstead