Index

A B C D E F G H I K L M N P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractKafkaSchemaSerDe - Class in io.confluent.kafka.serializers

Common fields and helper methods for both the serializer and the deserializer.

AbstractKafkaSchemaSerDe() - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

AbstractKafkaSchemaSerDe.ExtendedSchema - Class in io.confluent.kafka.serializers

AbstractKafkaSchemaSerDe.Migration - Class in io.confluent.kafka.serializers

AbstractKafkaSchemaSerDe.SubjectSchema - Class in io.confluent.kafka.serializers

AbstractKafkaSchemaSerDeConfig - Class in io.confluent.kafka.serializers

Base class for configs for serializers and deserializers, defining a few common configs and defaults.

AbstractKafkaSchemaSerDeConfig(ConfigDef, Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AbstractKafkaSchemaSerDeConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AUTO_REGISTER_SCHEMAS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AUTO_REGISTER_SCHEMAS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

AUTO_REGISTER_SCHEMAS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

autoRegisterSchema() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

B

baseConfigDef() - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BASIC_AUTH_CREDENTIALS_SOURCE - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BASIC_AUTH_CREDENTIALS_SOURCE_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BASIC_AUTH_CREDENTIALS_SOURCE_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

basicAuthUserInfo() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CLIENT_ID - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CLIENT_ID_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CLIENT_SECRET - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CLIENT_SECRET_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CREDENTIALS_SOURCE - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CREDENTIALS_SOURCE_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CREDENTIALS_SOURCE_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CUSTOM_PROVIDER_CLASS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_CUSTOM_PROVIDER_CLASS_D0C - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_IDENTITY_POOL_ID - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_IDENTITY_POOL_ID_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_ISSUER_ENDPOINT_URL - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_ISSUER_ENDPOINT_URL_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_LOGICAL_CLUSTER - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_LOGICAL_CLUSTER_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SCOPE - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SCOPE_CLAIM_NAME - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SCOPE_CLAIM_NAME_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SCOPE_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SUB_CLAIM_NAME - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_SUB_CLAIM_NAME_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_TOKEN_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_TOKEN_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

BEARER_AUTH_TOKEN_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

C

clearKey() - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

close() - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

close() - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

close() - Method in class io.confluent.kafka.formatter.SchemaMessageReader

close() - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

close() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

close() - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdDeserializer

close() - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdSerializer

close() - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

close() - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

close() - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

COMPOSITE_CONFLUENT_DESERIALIZER - Static variable in class io.confluent.kafka.serializers.wrapper.CompositeDeserializerConfig

COMPOSITE_CONFLUENT_DESERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.wrapper.CompositeDeserializerConfig

COMPOSITE_OLD_DESERIALIZER - Static variable in class io.confluent.kafka.serializers.wrapper.CompositeDeserializerConfig

COMPOSITE_OLD_DESERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.wrapper.CompositeDeserializerConfig

CompositeDeserializer - Class in io.confluent.kafka.serializers.wrapper

CompositeDeserializer() - Constructor for class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

Constructor used by Kafka consumer.

CompositeDeserializerConfig - Class in io.confluent.kafka.serializers.wrapper

CompositeDeserializerConfig(Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.wrapper.CompositeDeserializerConfig

config - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

configOriginals - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

ConfigSchemaIdDeserializer - Class in io.confluent.kafka.serializers.schema.id

A ConfigSchemaIdDeserializer returns a schema ID that is configured using the property "use.schema.id" or "use.schema.guid".

ConfigSchemaIdDeserializer() - Constructor for class io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

configure(CompositeDeserializerConfig, boolean) - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

configure(WrapperKeyDeserializerConfig, boolean) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

configure(WrapperKeySerializerConfig, boolean) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

configure(Map<String, ?>) - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

configure(Map<String, ?>) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.context.NullContextNameStrategy

configure(Map<String, ?>) - Method in interface io.confluent.kafka.serializers.context.strategy.ContextNameStrategy

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

configure(Map<String, ?>) - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdDeserializer

configure(Map<String, ?>) - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdSerializer

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.subject.DefaultReferenceSubjectNameStrategy

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.subject.QualifiedReferenceSubjectNameStrategy

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.subject.RecordNameStrategy

configure(Map<String, ?>) - Method in class io.confluent.kafka.serializers.subject.TopicNameStrategy

configure(Map<String, ?>, boolean) - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

configure(Map<String, ?>, boolean) - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

configureClientProperties(AbstractKafkaSchemaSerDeConfig, SchemaProvider) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

CONTEXT_NAME_STRATEGY - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

CONTEXT_NAME_STRATEGY_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

CONTEXT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

contextName(String) - Method in class io.confluent.kafka.serializers.context.NullContextNameStrategy

For a given topic, returns the context name to use.

contextName(String) - Method in interface io.confluent.kafka.serializers.context.strategy.ContextNameStrategy

For a given topic, returns the context name to use.

contextNameStrategy - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

contextNameStrategy() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

ContextNameStrategy - Interface in io.confluent.kafka.serializers.context.strategy

A ContextNameStrategy is used by a serializer or deserializer to determine the context name used with the schema registry.

createDeserializer(Deserializer) - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

createSerializer(Serializer) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

D

DEFAULT_BEARER_AUTH_SCOPE_CLAIM_NAME - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

DEFAULT_BEARER_AUTH_SUB_CLAIM_NAME - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

DEFAULT_CACHE_CAPACITY - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

DefaultReferenceSubjectNameStrategy - Class in io.confluent.kafka.serializers.subject

Default ReferenceSubjectNameStrategy: simply uses the reference name as the subject name.

DefaultReferenceSubjectNameStrategy() - Constructor for class io.confluent.kafka.serializers.subject.DefaultReferenceSubjectNameStrategy

deserialize(String, boolean, Headers, byte[], SchemaId) - Method in class io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

deserialize(String, boolean, Headers, byte[], SchemaId) - Method in class io.confluent.kafka.serializers.schema.id.DualSchemaIdDeserializer

deserialize(String, boolean, Headers, byte[], SchemaId) - Method in class io.confluent.kafka.serializers.schema.id.PrefixSchemaIdDeserializer

deserialize(String, boolean, Headers, byte[], SchemaId) - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdDeserializer

Deserialize the payload and set the schema identifier.

deserialize(String, byte[]) - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

deserialize(String, byte[]) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

deserialize(String, Boolean, Headers, byte[]) - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

deserialize(String, Headers, byte[]) - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

deserialize(String, Headers, byte[]) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

deserializeKey(String, Headers, byte[]) - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

deserializer - Variable in class io.confluent.kafka.formatter.SchemaMessageFormatter

DeserializerWithSchema<T> - Interface in io.confluent.kafka.serializers

deserializeWithSchema(String, Headers, byte[]) - Method in interface io.confluent.kafka.serializers.DeserializerWithSchema

DualSchemaIdDeserializer - Class in io.confluent.kafka.serializers.schema.id

A DualSchemaIdDeserializer first looks for a schema GUID in the header; if not found it looks for a schema ID in the payload prefix.

DualSchemaIdDeserializer() - Constructor for class io.confluent.kafka.serializers.schema.id.DualSchemaIdDeserializer

E

enableRuleServiceLoader - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

enableRuleServiceLoader() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

equals(Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

equals(Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

equals(Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

equals(Object) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

executeMigrations(List<AbstractKafkaSchemaSerDe.Migration>, String, String, Headers, Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

executeRules(String, String, Headers, RuleMode, ParsedSchema, ParsedSchema, Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

executeRules(String, String, Headers, Object, RuleMode, ParsedSchema, ParsedSchema, Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

executeRules(String, String, Headers, Object, RulePhase, RuleMode, ParsedSchema, ParsedSchema, Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

ExtendedSchema(Integer, Integer, String, ParsedSchema) - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

F

fromBytes(ByteBuffer) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

G

getById(int) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Deprecated.

getBySubjectAndId(String, int) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Deprecated.

getConfluentDeserializer() - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

getContextName(String) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getContextName(String, String) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getGuid() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

getGuid() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

getId() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

getId() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

getIdCompatibilityStrict() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getKeyDeserializer() - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

getKeySerializer() - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

getLatestCacheSize() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getLatestCacheTtl() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getLatestCompatibilityStrict() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getLatestWithMetadata(String) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getLatestWithMetadataSpec() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getMaxSchemasPerSubject() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getMessageIndexes() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

getMessageIndexesAsBytes() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

getMigrations(String, ParsedSchema, ParsedSchema) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getOldDeserializer() - Method in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

getOldSubjectName(Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Get the subject name used by the old Encoder interface, which relies only on the value type rather than the topic.

getProvider() - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

getProvider() - Method in class io.confluent.kafka.formatter.SchemaMessageReader

getRecordName(ParsedSchema, boolean) - Method in class io.confluent.kafka.serializers.subject.RecordNameStrategy

If the schema is a record type, returns its fully-qualified name.

getRuleActions() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getRuleExecutors() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getRuleMode() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

getSchema() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

getSchema() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

getSchemaById(int) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getSchemaBySchemaId(String, SchemaId) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getSchemaFormat() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getSchemaRegistryClient() - Method in interface io.confluent.kafka.formatter.SchemaMessageDeserializer

getSchemaRegistryClient() - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

getSchemaRegistryClient() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

getSchemaRegistryUrls() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

getSchemaType() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

getSource() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

getSubject() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

getSubjectName(String, boolean, Object, ParsedSchema) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Get the subject name for the given topic and value type.

getTarget() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

getVersion() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

guidToBytes() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

H

hashCode() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.ExtendedSchema

hashCode() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

hashCode() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

hashCode() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

HeaderSchemaIdSerializer - Class in io.confluent.kafka.serializers.schema.id

A HeaderSchemaIdSerializer adds a schema GUID to the header.

HeaderSchemaIdSerializer() - Constructor for class io.confluent.kafka.serializers.schema.id.HeaderSchemaIdSerializer

HTTP_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

HTTP_CONNECT_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

HTTP_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

HTTP_READ_TIMEOUT_MS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

HTTP_READ_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

HTTP_READ_TIMEOUT_MS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

I

ID_COMPATIBILITY_STRICT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

ID_COMPATIBILITY_STRICT_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

ID_COMPATIBILITY_STRICT_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

ID_SIZE - Static variable in class io.confluent.kafka.serializers.schema.id.SchemaId

idToBytes() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

init(Properties) - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

init(Properties) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

io.confluent.kafka.formatter - package io.confluent.kafka.formatter

io.confluent.kafka.serializers - package io.confluent.kafka.serializers

io.confluent.kafka.serializers.context - package io.confluent.kafka.serializers.context

io.confluent.kafka.serializers.context.strategy - package io.confluent.kafka.serializers.context.strategy

io.confluent.kafka.serializers.schema.id - package io.confluent.kafka.serializers.schema.id

io.confluent.kafka.serializers.subject - package io.confluent.kafka.serializers.subject

io.confluent.kafka.serializers.subject.strategy - package io.confluent.kafka.serializers.subject.strategy

io.confluent.kafka.serializers.wrapper - package io.confluent.kafka.serializers.wrapper

isKey - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

isKey() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

K

key() - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

KEY_SCHEMA - Static variable in class io.confluent.kafka.formatter.SchemaMessageReader

KEY_SCHEMA_ID_DESERIALIZER - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SCHEMA_ID_DESERIALIZER_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SCHEMA_ID_DESERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SCHEMA_ID_HEADER - Static variable in class io.confluent.kafka.serializers.schema.id.SchemaId

KEY_SCHEMA_ID_SERIALIZER - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SCHEMA_ID_SERIALIZER_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SCHEMA_ID_SERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SUBJECT_NAME_STRATEGY - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SUBJECT_NAME_STRATEGY_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

KEY_SUBJECT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

keySchema - Variable in class io.confluent.kafka.formatter.SchemaMessageReader

keySchemaIdDeserializer - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

keySchemaIdDeserializer() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

keySchemaIdSerializer - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

keySchemaIdSerializer() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

keySubjectNameStrategy - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

keySubjectNameStrategy() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

L

LATEST_CACHE_SIZE - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_CACHE_SIZE_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_CACHE_SIZE_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_CACHE_TTL - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_CACHE_TTL_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_COMPATIBILITY_STRICT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_COMPATIBILITY_STRICT_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

LATEST_COMPATIBILITY_STRICT_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

latestVersions - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

latestVersionsCache() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

latestWithMetadata - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

latestWithMetadataCache() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

log - Variable in class io.confluent.kafka.serializers.wrapper.CompositeDeserializer

lookupLatestVersion(SchemaRegistryClient, String, ParsedSchema, Map<AbstractKafkaSchemaSerDe.SubjectSchema, AbstractKafkaSchemaSerDe.ExtendedSchema>, boolean) - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

lookupLatestVersion(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

lookupSchemaBySubjectAndId(String, int, ParsedSchema, boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

M

MAGIC_BYTE_V0 - Static variable in class io.confluent.kafka.serializers.schema.id.SchemaId

MAGIC_BYTE_V1 - Static variable in class io.confluent.kafka.serializers.schema.id.SchemaId

MAX_RETRIES_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

MAX_RETRIES_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

MAX_RETRIES_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

MAX_SCHEMAS_PER_SUBJECT_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

MAX_SCHEMAS_PER_SUBJECT_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

MAX_SCHEMAS_PER_SUBJECT_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

metadata - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Migration(RuleMode, ParsedSchema, ParsedSchema) - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration

N

NORMALIZE_SCHEMAS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

NORMALIZE_SCHEMAS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

NORMALIZE_SCHEMAS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

normalizeSchema() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

NullContextNameStrategy - Class in io.confluent.kafka.serializers.context

A NullContextNameStrategy that returns null (indicating no specific context).

NullContextNameStrategy() - Constructor for class io.confluent.kafka.serializers.context.NullContextNameStrategy

P

parseSchema(SchemaRegistryClient, String, List<SchemaReference>) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

postOp(Object) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

PrefixSchemaIdDeserializer - Class in io.confluent.kafka.serializers.schema.id

A PrefixSchemaIdDeserializer looks for a schema ID in the payload prefix.

PrefixSchemaIdDeserializer() - Constructor for class io.confluent.kafka.serializers.schema.id.PrefixSchemaIdDeserializer

PrefixSchemaIdSerializer - Class in io.confluent.kafka.serializers.schema.id

A PrefixSchemaIdSerializer adds a schema ID to the payload prefix.

PrefixSchemaIdSerializer() - Constructor for class io.confluent.kafka.serializers.schema.id.PrefixSchemaIdSerializer

PROPAGATE_SCHEMA_TAGS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROPAGATE_SCHEMA_TAGS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROPAGATE_SCHEMA_TAGS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

propagateSchemaTags() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_HOST - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_HOST_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_HOST_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_PORT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_PORT_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

PROXY_PORT_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

Q

QualifiedReferenceSubjectNameStrategy - Class in io.confluent.kafka.serializers.subject

An implementation of ReferenceSubjectNameStrategy that makes a reference name that represents a path appear as a qualified name.

QualifiedReferenceSubjectNameStrategy() - Constructor for class io.confluent.kafka.serializers.subject.QualifiedReferenceSubjectNameStrategy

R

readFrom(String, ParsedSchema) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

readRecords(InputStream) - Method in class io.confluent.kafka.formatter.SchemaMessageReader

RecordNameStrategy - Class in io.confluent.kafka.serializers.subject

For any record type that is published to Kafka, registers the schema in the registry under the fully-qualified record name (regardless of the topic).

RecordNameStrategy() - Constructor for class io.confluent.kafka.serializers.subject.RecordNameStrategy

ReferenceSubjectNameStrategy - Interface in io.confluent.kafka.serializers.subject.strategy

A ReferenceSubjectNameStrategy is used by the serializer to determine the subject name under which the referenced schema should be registered in the schema registry.

register(String, ParsedSchema) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

register(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

register(String, Schema) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Deprecated.

registerWithResponse(String, ParsedSchema, boolean, boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

REQUEST_HEADER_PREFIX - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

Configurations beginning with this prefix can be used to specify headers to include in requests made to Schema Registry.

requestHeaders() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_MAX_WAIT_MS_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_MAX_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_MAX_WAIT_MS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_WAIT_MS_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RETRIES_WAIT_MS_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_ACTIONS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_ACTIONS_DOCS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_EXECUTORS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_EXECUTORS_DOCS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_SERVICE_LOADER_ENABLE - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

RULE_SERVICE_LOADER_ENABLE_DOCS - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

ruleActions - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

ruleExecutors - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

S

SCHEMA_FORMAT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_FORMAT_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REFLECTION_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REFLECTION_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REFLECTION_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_URL_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_URL_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_URL_RANDOMIZE_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_URL_RANDOMIZE_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_URL_RANDOMIZE_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_USER_INFO_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

Deprecated.

use AbstractKafkaSchemaSerDeConfig.USER_INFO_CONFIG instead

SCHEMA_REGISTRY_USER_INFO_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SCHEMA_REGISTRY_USER_INFO_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

SchemaId - Class in io.confluent.kafka.serializers.schema.id

A SchemaId is used to identify a schema.

SchemaId(String) - Constructor for class io.confluent.kafka.serializers.schema.id.SchemaId

SchemaId(String, Integer, String) - Constructor for class io.confluent.kafka.serializers.schema.id.SchemaId

SchemaId(String, Integer, UUID) - Constructor for class io.confluent.kafka.serializers.schema.id.SchemaId

schemaIdDeserializer(boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

SchemaIdDeserializer - Interface in io.confluent.kafka.serializers.schema.id

A SchemaIdDeserializer is used by a deserializer to determine how to deserialize schema identifiers.

schemaIdSerializer(boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

SchemaIdSerializer - Interface in io.confluent.kafka.serializers.schema.id

A SchemaIdSerializer is used by a serializer to determine how to serialize schema identifiers.

SchemaMessageDeserializer<T> - Interface in io.confluent.kafka.formatter

SchemaMessageFormatter<T> - Class in io.confluent.kafka.formatter

SchemaMessageFormatter() - Constructor for class io.confluent.kafka.formatter.SchemaMessageFormatter

Constructor needed by kafka console consumer.

SchemaMessageFormatter(String, Deserializer) - Constructor for class io.confluent.kafka.formatter.SchemaMessageFormatter

For testing only.

SchemaMessageReader<T> - Class in io.confluent.kafka.formatter

SchemaMessageReader() - Constructor for class io.confluent.kafka.formatter.SchemaMessageReader

Constructor needed by kafka console producer.

SchemaMessageReader(String, ParsedSchema, ParsedSchema, String, boolean, boolean, boolean, boolean) - Constructor for class io.confluent.kafka.formatter.SchemaMessageReader

For testing only.

SchemaMessageSerializer<T> - Interface in io.confluent.kafka.formatter

schemaRegistry - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

serialize(String, boolean, Headers, byte[], SchemaId) - Method in class io.confluent.kafka.serializers.schema.id.HeaderSchemaIdSerializer

serialize(String, boolean, Headers, byte[], SchemaId) - Method in class io.confluent.kafka.serializers.schema.id.PrefixSchemaIdSerializer

serialize(String, boolean, Headers, byte[], SchemaId) - Method in interface io.confluent.kafka.serializers.schema.id.SchemaIdSerializer

Associates a schema identifier with the payload.

serialize(String, String, boolean, Headers, T, ParsedSchema) - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

serialize(String, Headers, T) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

serialize(String, T) - Method in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

serializeKey(String, Headers, Object) - Method in interface io.confluent.kafka.formatter.SchemaMessageSerializer

setGuid(UUID) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

setId(Integer) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

setKey(Object) - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

setMessageIndexes(byte[]) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

setMessageIndexes(ByteBuffer) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

setMessageIndexes(List<Integer>) - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

strategyUsesSchema(boolean) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

subjectName(String, boolean, ParsedSchema) - Method in class io.confluent.kafka.serializers.subject.RecordNameStrategy

subjectName(String, boolean, ParsedSchema) - Method in interface io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy

For a given topic and message, returns the subject name under which the schema should be registered in the schema registry.

subjectName(String, boolean, ParsedSchema) - Method in class io.confluent.kafka.serializers.subject.TopicNameStrategy

subjectName(String, boolean, ParsedSchema) - Method in class io.confluent.kafka.serializers.subject.TopicRecordNameStrategy

subjectName(String, String, boolean, ParsedSchema) - Method in class io.confluent.kafka.serializers.subject.DefaultReferenceSubjectNameStrategy

subjectName(String, String, boolean, ParsedSchema) - Method in class io.confluent.kafka.serializers.subject.QualifiedReferenceSubjectNameStrategy

Given a reference name, this method returns a subject name.

subjectName(String, String, boolean, ParsedSchema) - Method in interface io.confluent.kafka.serializers.subject.strategy.ReferenceSubjectNameStrategy

For a given reference name, topic, and message, returns the subject name under which the referenced schema should be registered in the schema registry.

SubjectNameStrategy - Interface in io.confluent.kafka.serializers.subject.strategy

A SubjectNameStrategy is used by the serializer to determine the subject name under which the event record schemas should be registered in the schema registry.

SubjectSchema(String, ParsedSchema) - Constructor for class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

T

ticker - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

ticker(SchemaRegistryClient) - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

toKafkaException(RestClientException, String) - Static method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

TopicNameStrategy - Class in io.confluent.kafka.serializers.subject

Default SubjectNameStrategy: for any messages published to <topic>, the schema of the message key is registered under the subject name <topic>-key, and the message value is registered under the subject name <topic>-value.

TopicNameStrategy() - Constructor for class io.confluent.kafka.serializers.subject.TopicNameStrategy

TopicRecordNameStrategy - Class in io.confluent.kafka.serializers.subject

For any record type that is published to Kafka topic <topic>, registers the schema in the registry under the subject name <topic>-<recordName>, where <recordName> is the fully-qualified record name.

TopicRecordNameStrategy() - Constructor for class io.confluent.kafka.serializers.subject.TopicRecordNameStrategy

toString() - Method in class io.confluent.kafka.serializers.schema.id.SchemaId

U

USE_LATEST_VERSION - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_LATEST_VERSION_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_LATEST_VERSION_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_LATEST_WITH_METADATA - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_LATEST_WITH_METADATA_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_SCHEMA_GUID - Static variable in class io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

USE_SCHEMA_ID - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_SCHEMA_ID - Static variable in class io.confluent.kafka.serializers.schema.id.ConfigSchemaIdDeserializer

USE_SCHEMA_ID_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USE_SCHEMA_ID_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

useLatestVersion - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

useLatestVersion() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USER_INFO_CONFIG - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

USER_INFO_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

useSchemaId() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

useSchemaReflection - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

useSchemaReflection() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

usesSchema() - Method in class io.confluent.kafka.serializers.subject.RecordNameStrategy

usesSchema() - Method in interface io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy

Whether the strategy depends on the schema.

usesSchema() - Method in class io.confluent.kafka.serializers.subject.TopicRecordNameStrategy

V

VALUE_SCHEMA - Static variable in class io.confluent.kafka.formatter.SchemaMessageReader

VALUE_SCHEMA_ID_DESERIALIZER - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SCHEMA_ID_DESERIALIZER_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SCHEMA_ID_DESERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SCHEMA_ID_HEADER - Static variable in class io.confluent.kafka.serializers.schema.id.SchemaId

VALUE_SCHEMA_ID_SERIALIZER - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SCHEMA_ID_SERIALIZER_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SCHEMA_ID_SERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SUBJECT_NAME_STRATEGY - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SUBJECT_NAME_STRATEGY_DEFAULT - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

VALUE_SUBJECT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

valueSchema - Variable in class io.confluent.kafka.formatter.SchemaMessageReader

valueSchemaIdDeserializer - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

valueSchemaIdDeserializer() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

valueSchemaIdSerializer - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

valueSchemaIdSerializer() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

valueSubjectNameStrategy - Variable in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

valueSubjectNameStrategy() - Method in class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

W

WRAPPED_KEY_DESERIALIZER - Static variable in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializerConfig

WRAPPED_KEY_DESERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializerConfig

WRAPPED_KEY_SERIALIZER - Static variable in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializerConfig

WRAPPED_KEY_SERIALIZER_DOC - Static variable in class io.confluent.kafka.serializers.wrapper.WrapperKeySerializerConfig

WrapperKeyDeserializer<T> - Class in io.confluent.kafka.serializers.wrapper

WrapperKeyDeserializer() - Constructor for class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializer

Constructor used by Kafka consumer.

WrapperKeyDeserializerConfig - Class in io.confluent.kafka.serializers.wrapper

WrapperKeyDeserializerConfig(Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.wrapper.WrapperKeyDeserializerConfig

WrapperKeySerializer<T> - Class in io.confluent.kafka.serializers.wrapper

WrapperKeySerializer() - Constructor for class io.confluent.kafka.serializers.wrapper.WrapperKeySerializer

Constructor used by Kafka producer.

WrapperKeySerializerConfig - Class in io.confluent.kafka.serializers.wrapper

WrapperKeySerializerConfig(Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.wrapper.WrapperKeySerializerConfig

writeTo(String, Boolean, Headers, byte[], PrintStream) - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class io.confluent.kafka.formatter.SchemaMessageFormatter

A B C D E F G H I K L M N P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values