Package io.confluent.kafka.serializers.protobuf

Class KafkaProtobufSerializerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

public class KafkaProtobufSerializerConfig
extends AbstractKafkaSchemaSerDeConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	REFERENCE_LOOKUP_ONLY_CONFIG
static final String	REFERENCE_LOOKUP_ONLY_DOC
static final String	REFERENCE_SUBJECT_NAME_STRATEGY_CONFIG
static final String	REFERENCE_SUBJECT_NAME_STRATEGY_DOC
static final String	SKIP_KNOWN_TYPES_CONFIG
static final String	SKIP_KNOWN_TYPES_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, 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_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_ID, USE_SCHEMA_ID_DEFAULT, USE_SCHEMA_ID_DOC, USER_INFO_CONFIG, USER_INFO_DEFAULT, 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
KafkaProtobufSerializerConfig(Map<?,?> props)

Method Summary

Modifier and Type	Method	Description
boolean	onlyLookupReferencesBySchema()
ReferenceSubjectNameStrategy	referenceSubjectNameStrategyInstance()
boolean	skipKnownTypes()

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

autoRegisterSchema, baseConfigDef, basicAuthUserInfo, contextNameStrategy, enableRuleServiceLoader, getIdCompatibilityStrict, getLatestCacheSize, getLatestCacheTtl, getLatestCompatibilityStrict, getLatestWithMetadataSpec, getMaxSchemasPerSubject, getSchemaFormat, getSchemaRegistryUrls, keySchemaIdDeserializer, keySchemaIdSerializer, keySubjectNameStrategy, normalizeSchema, propagateSchemaTags, requestHeaders, useLatestVersion, 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, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Details

REFERENCE_LOOKUP_ONLY_CONFIG

public static final String REFERENCE_LOOKUP_ONLY_CONFIG

See Also:

• Constant Field Values

REFERENCE_LOOKUP_ONLY_DOC

public static final String REFERENCE_LOOKUP_ONLY_DOC

See Also:

• Constant Field Values

SKIP_KNOWN_TYPES_CONFIG

public static final String SKIP_KNOWN_TYPES_CONFIG

See Also:

• Constant Field Values

SKIP_KNOWN_TYPES_DOC

public static final String SKIP_KNOWN_TYPES_DOC

See Also:

• Constant Field Values

REFERENCE_SUBJECT_NAME_STRATEGY_CONFIG

public static final String REFERENCE_SUBJECT_NAME_STRATEGY_CONFIG

See Also:

• Constant Field Values

REFERENCE_SUBJECT_NAME_STRATEGY_DOC

public static final String REFERENCE_SUBJECT_NAME_STRATEGY_DOC

See Also:

• Constant Field Values

Constructor Details

KafkaProtobufSerializerConfig

public KafkaProtobufSerializerConfig(Map<?,?> props)

Method Details

onlyLookupReferencesBySchema

public boolean onlyLookupReferencesBySchema()

skipKnownTypes

public boolean skipKnownTypes()

referenceSubjectNameStrategyInstance

public ReferenceSubjectNameStrategy referenceSubjectNameStrategyInstance()