Skip navigation links
A C D E F G H I J K L M N P R S T U V W 

A

AbstractCrudIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
AbstractCrudIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
AbstractKafkaDeserializer<T,U,S extends AbstractKafkaDeserializer<T,U,S>> - Class in io.apicurio.registry.utils.serde
 
AbstractKafkaDeserializer() - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
AbstractKafkaDeserializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
AbstractKafkaSerDe<T extends AbstractKafkaSerDe<T>> - Class in io.apicurio.registry.utils.serde
Common class for both serializer and deserializer.
AbstractKafkaSerDe() - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
AbstractKafkaSerDe(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
AbstractKafkaSerializer<T,U,S extends AbstractKafkaSerializer<T,U,S>> - Class in io.apicurio.registry.utils.serde
 
AbstractKafkaSerializer() - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
AbstractKafkaSerializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
AbstractKafkaSerializer(RegistryService, ArtifactIdStrategy<T>, GlobalIdStrategy<T>) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
AbstractKafkaStrategyAwareSerDe<T,S extends AbstractKafkaStrategyAwareSerDe<T,S>> - Class in io.apicurio.registry.utils.serde
 
AbstractKafkaStrategyAwareSerDe() - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
AbstractKafkaStrategyAwareSerDe(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
AbstractKafkaStrategyAwareSerDe(RegistryService, ArtifactIdStrategy<T>, GlobalIdStrategy<T>) - Constructor for class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
AbstractSerde<T> - Class in io.apicurio.registry.utils.serde
 
addEncodingHeader(Headers, AvroEncoding) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
addSchemaHeaders(Headers, String, long) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Adds appropriate information to the Headers so that the deserializer can function properly.
addSchemaHeaders(Headers, String, long) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
Adds appropriate information to the Headers so that the deserializer can function properly.
addTypeHeaders(Headers, T) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Adds appropriate information to the Headers so that the deserializer can function properly.
afterCreateArtifact(T, ArtifactMetaData) - Method in class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
afterCreateArtifact(T, ArtifactMetaData) - Method in class io.apicurio.registry.utils.serde.strategy.CachedSchemaIdStrategy
 
api - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 
artifactId(String, boolean, T) - Method in interface io.apicurio.registry.utils.serde.strategy.ArtifactIdStrategy
For a given topic and message, returns the artifact id under which the schema should be registered in the registry.
artifactId(String, boolean, Schema) - Method in class io.apicurio.registry.utils.serde.strategy.RecordIdStrategy
 
artifactId(String, boolean, T) - Method in class io.apicurio.registry.utils.serde.strategy.SimpleTopicIdStrategy
 
artifactId(String, boolean, T) - Method in class io.apicurio.registry.utils.serde.strategy.TopicIdStrategy
 
artifactId(String, boolean, Schema) - Method in class io.apicurio.registry.utils.serde.strategy.TopicRecordIdStrategy
 
artifactIdHeaderName - Variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
ArtifactIdStrategy<T> - Interface in io.apicurio.registry.utils.serde.strategy
A ArtifactIdStrategy is used by the Kafka serializer/deserializer to determine the artifact id under which the message schemas should be registered in the registry.
artifactType() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
artifactType() - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
artifactType() - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
asLegacyId() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
AutoRegisterIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
AutoRegisterIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.AutoRegisterIdStrategy
 
AVRO_BINARY - Static variable in enum io.apicurio.registry.utils.serde.AvroEncoding
 
AVRO_ENCODING - Static variable in enum io.apicurio.registry.utils.serde.AvroEncoding
 
AVRO_JSON - Static variable in enum io.apicurio.registry.utils.serde.AvroEncoding
 
AvroDatumProvider<T> - Interface in io.apicurio.registry.utils.serde.avro
 
AvroEncoding - Enum in io.apicurio.registry.utils.serde
 
AvroKafkaDeserializer<U> - Class in io.apicurio.registry.utils.serde
 
AvroKafkaDeserializer() - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
AvroKafkaDeserializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
AvroKafkaDeserializer(RegistryService, AvroDatumProvider<U>) - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
AvroKafkaSerializer<U> - Class in io.apicurio.registry.utils.serde
 
AvroKafkaSerializer() - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
AvroKafkaSerializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
AvroKafkaSerializer(RegistryService, ArtifactIdStrategy<Schema>, GlobalIdStrategy<Schema>) - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
AvroKafkaSerializer(RegistryService, ArtifactIdStrategy<Schema>, GlobalIdStrategy<Schema>, AvroDatumProvider<U>) - Constructor for class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
AvroSchemaUtils - Class in io.apicurio.registry.utils.serde.avro
 
AvroSchemaUtils() - Constructor for class io.apicurio.registry.utils.serde.avro.AvroSchemaUtils
 
AvroSerde<T> - Class in io.apicurio.registry.utils.serde
Wraps the AvroKafkaSerializer and AvroKafkaDeserializer.
AvroSerde() - Constructor for class io.apicurio.registry.utils.serde.AvroSerde
 

C

CachedSchemaIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
We first check client-side cache for matching schema, if none matches, we check server-side, create new if none matches (and cache it).
CachedSchemaIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.CachedSchemaIdStrategy
 
clear() - Method in class io.apicurio.registry.utils.serde.SchemaCache
 
close() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
close() - Method in class io.apicurio.registry.utils.serde.AbstractSerde
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractSerde
 
configure(Map<String, ?>) - Method in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
configure(Map<String, ?>) - Method in class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 
createDatumReader(Schema) - Method in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
createDatumReader(Schema) - Method in class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
createDatumReader(Schema) - Method in class io.apicurio.registry.utils.serde.avro.ReflectAvroDatumProvider
 
createDatumWriter(T, Schema) - Method in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
createDatumWriter(T, Schema) - Method in class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
createDatumWriter(T, Schema) - Method in class io.apicurio.registry.utils.serde.avro.ReflectAvroDatumProvider
 
createHeaders() - Static method in class io.apicurio.registry.utils.serde.util.HeaderUtils
Create an empty set of Kafka headers.
createHeaders(Map<String, String>) - Static method in class io.apicurio.registry.utils.serde.util.HeaderUtils
Create Kafka headers from a map of String keys and String values.

D

DEFAULT_HEADER_KEY_ARTIFACT_ID - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DEFAULT_HEADER_KEY_GLOBAL_ID - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DEFAULT_HEADER_KEY_VERSION - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DEFAULT_HEADER_VALUE_ARTIFACT_ID - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DEFAULT_HEADER_VALUE_GLOBAL_ID - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DEFAULT_HEADER_VALUE_VERSION - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
DefaultAvroDatumProvider<T> - Class in io.apicurio.registry.utils.serde.avro
 
DefaultAvroDatumProvider() - Constructor for class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
DefaultAvroDatumProvider(boolean) - Constructor for class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
DefaultIdHandler - Class in io.apicurio.registry.utils.serde.strategy
 
DefaultIdHandler() - Constructor for class io.apicurio.registry.utils.serde.strategy.DefaultIdHandler
 
deserialize(String, byte[]) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
deserialize(String, Headers, byte[]) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
deserialize(String, byte[]) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
 
deserialize(String, Headers, byte[]) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
 
deserializer() - Method in class io.apicurio.registry.utils.serde.AbstractSerde
 

E

encodingName - Variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
equals(Object) - Method in class io.apicurio.registry.utils.serde.avro.NonRecordContainer
 

F

FindBySchemaIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
FindBySchemaIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.FindBySchemaIdStrategy
 
findId(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
findId(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.FindBySchemaIdStrategy
 
findId(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.FindLatestIdStrategy
 
findId(RegistryService, String, ArtifactType, T) - Method in interface io.apicurio.registry.utils.serde.strategy.GlobalIdStrategy
For a given topic and message, returns the artifact id under which the schema should be registered in the registry.
FindLatestIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
FindLatestIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.FindLatestIdStrategy
 
fromConfig(Map<String, ?>) - Static method in enum io.apicurio.registry.utils.serde.AvroEncoding
 

G

getArtifactId(Headers) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Gets the artifact id from the headers.
getArtifactId(String, T) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Figure out the artifact ID from the topic name and data.
getArtifactId(Headers) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
getArtifactIdStrategy() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
getByteBuffer(byte[]) - Static method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
getClient() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
getEncoding(Headers) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
getGlobalId(Headers) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Gets the global id from the headers.
getGlobalId(String, String, T) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Gets the global id of the schema to use for validation.
getGlobalId(Headers) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
getGlobalIdStrategy() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
getIdHandler() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
getMessageType(Headers) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Gets the message type from the headers.
GetOrCreateIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
GetOrCreateIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.GetOrCreateIdStrategy
 
getSchema() - Method in class io.apicurio.registry.utils.serde.avro.NonRecordContainer
 
getSchema(long) - Method in class io.apicurio.registry.utils.serde.SchemaCache
 
getSchemaCache() - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 
getValue() - Method in class io.apicurio.registry.utils.serde.avro.NonRecordContainer
 
getVersion(Headers) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Gets the artifact version from the headers.
getVersion(Headers) - Method in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
globalIdHeaderName - Variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
GlobalIdStrategy<T> - Interface in io.apicurio.registry.utils.serde.strategy
A GlobalIdStrategy is used by the Kafka serializer/deserializer to find global id for given schema in the registry.

H

hashCode() - Method in class io.apicurio.registry.utils.serde.avro.NonRecordContainer
 
HEADER_ARTIFACT_ID - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 
HEADER_GLOBAL_ID - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 
HEADER_KEY_ARTIFACT_ID_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_KEY_ENCODING - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_KEY_GLOBAL_ID_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_KEY_VERSION_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_MSG_TYPE - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 
HEADER_VALUE_ARTIFACT_ID_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_VALUE_ENCODING - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_VALUE_GLOBAL_ID_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_VALUE_VERSION_OVERRIDE_NAME - Static variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 
HEADER_VERSION - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 
headerUtils - Variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
HeaderUtils - Class in io.apicurio.registry.utils.serde.util
 
HeaderUtils(Map<String, Object>, boolean) - Constructor for class io.apicurio.registry.utils.serde.util.HeaderUtils
 

I

IdHandler - Interface in io.apicurio.registry.utils.serde.strategy
Handle artifact id in the msg bytes.
idSize() - Method in class io.apicurio.registry.utils.serde.strategy.DefaultIdHandler
 
idSize() - Method in interface io.apicurio.registry.utils.serde.strategy.IdHandler
 
idSize() - Method in class io.apicurio.registry.utils.serde.strategy.Legacy4ByteIdHandler
 
initialLookup(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
initialLookup(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.AutoRegisterIdStrategy
 
initialLookup(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.CachedSchemaIdStrategy
 
initialLookup(RegistryService, String, ArtifactType, T) - Method in class io.apicurio.registry.utils.serde.strategy.GetOrCreateIdStrategy
 
instantiate(Class<V>, Object, Consumer<V>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
instantiate(Class<V>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
io.apicurio.registry.utils.serde - package io.apicurio.registry.utils.serde
 
io.apicurio.registry.utils.serde.avro - package io.apicurio.registry.utils.serde.avro
 
io.apicurio.registry.utils.serde.strategy - package io.apicurio.registry.utils.serde.strategy
 
io.apicurio.registry.utils.serde.util - package io.apicurio.registry.utils.serde.util
 
isKey() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
isNotFound(Response) - Method in class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
isPrimitive(Schema) - Static method in class io.apicurio.registry.utils.serde.avro.AvroSchemaUtils
 
isTrue(Object) - Static method in class io.apicurio.registry.utils.serde.util.Utils
 
isValidationEnabled() - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 

J

JsonSchemaKafkaDeserializer<T> - Class in io.apicurio.registry.utils.serde
 
JsonSchemaKafkaDeserializer() - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Constructor.
JsonSchemaKafkaDeserializer(RegistryService, Boolean) - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaDeserializer
Constructor.
JsonSchemaKafkaSerDe<S extends JsonSchemaKafkaSerDe<S>> - Class in io.apicurio.registry.utils.serde
 
JsonSchemaKafkaSerDe() - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
Constructor.
JsonSchemaKafkaSerDe(RegistryService, Boolean) - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
Constructor.
JsonSchemaKafkaSerializer<T> - Class in io.apicurio.registry.utils.serde
An implementation of the Kafka Serializer for JSON Schema use-cases.
JsonSchemaKafkaSerializer() - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Constructor.
JsonSchemaKafkaSerializer(RegistryService, Boolean) - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
Constructor.
JsonSchemaSerde<T> - Class in io.apicurio.registry.utils.serde
Wraps the JsonSchemaKafkaSerializer and JsonSchemaKafkaDeserializer.
JsonSchemaSerde() - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaSerde
 
JsonSchemaSerDeConstants - Class in io.apicurio.registry.utils.serde
 
JsonSchemaSerDeConstants() - Constructor for class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 

K

key - Variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 

L

Legacy4ByteIdHandler - Class in io.apicurio.registry.utils.serde.strategy
IdHandler that assumes 4 bytes for the magic number (the ID).
Legacy4ByteIdHandler() - Constructor for class io.apicurio.registry.utils.serde.strategy.Legacy4ByteIdHandler
 
loadClass(Class<V>, String) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
log - Variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 

M

MAGIC_BYTE - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
mapper - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 

N

NonRecordContainer<T> - Class in io.apicurio.registry.utils.serde.avro
Wrapper for all non-record types that includes the schema for the data.
NonRecordContainer(Schema, T) - Constructor for class io.apicurio.registry.utils.serde.avro.NonRecordContainer
 

P

parse(String) - Static method in class io.apicurio.registry.utils.serde.avro.AvroSchemaUtils
 
ProtobufKafkaDeserializer - Class in io.apicurio.registry.utils.serde
 
ProtobufKafkaDeserializer() - Constructor for class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
ProtobufKafkaDeserializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
ProtobufKafkaSerializer<U extends com.google.protobuf.Message> - Class in io.apicurio.registry.utils.serde
 
ProtobufKafkaSerializer() - Constructor for class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
ProtobufKafkaSerializer(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
ProtobufKafkaSerializer(RegistryService, ArtifactIdStrategy<byte[]>, GlobalIdStrategy<byte[]>) - Constructor for class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
ProtobufSerde<T extends com.google.protobuf.Message> - Class in io.apicurio.registry.utils.serde
Wraps the ProtobufKafkaSerializer and ProtobufKafkaDeserializer.
ProtobufSerde() - Constructor for class io.apicurio.registry.utils.serde.ProtobufSerde
 

R

readData(T, ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
readData(Headers, T, ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
readData(Schema, ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
readData(Headers, Schema, ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
readData(byte[], ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
readData(Headers, byte[], ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
readId(ByteBuffer) - Method in class io.apicurio.registry.utils.serde.strategy.DefaultIdHandler
 
readId(ByteBuffer) - Method in interface io.apicurio.registry.utils.serde.strategy.IdHandler
 
readId(ByteBuffer) - Method in class io.apicurio.registry.utils.serde.strategy.Legacy4ByteIdHandler
 
RecordIdStrategy - Class in io.apicurio.registry.utils.serde.strategy
 
RecordIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.RecordIdStrategy
 
ReflectAvroDatumProvider<T> - Class in io.apicurio.registry.utils.serde.avro
 
ReflectAvroDatumProvider() - Constructor for class io.apicurio.registry.utils.serde.avro.ReflectAvroDatumProvider
 
ReflectAvroDatumProvider(Class<T>) - Constructor for class io.apicurio.registry.utils.serde.avro.ReflectAvroDatumProvider
 
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
REGISTRY_AVRO_DATUM_PROVIDER_CONFIG_PARAM - Static variable in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
REGISTRY_CACHED_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
Deprecated.
REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
REGISTRY_ID_HANDLER_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_JSON_SCHEMA_VALIDATION_ENABLED - Static variable in class io.apicurio.registry.utils.serde.JsonSchemaSerDeConstants
 
REGISTRY_REQUEST_HEADERS_PREFIX - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_KEY_PASSWORD - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_KEYSTORE_LOCATION - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_KEYSTORE_PASSWORD - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_KEYSTORE_TYPE - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_TRUSTSTORE_LOCATION - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_TRUSTSTORE_PASSWORD - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_REQUEST_TRUSTSTORE_TYPE - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_URL_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
REGISTRY_USE_SPECIFIC_AVRO_READER_CONFIG_PARAM - Static variable in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
reset() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
reset() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 

S

SchemaCache<T> - Class in io.apicurio.registry.utils.serde
 
SchemaCache(RegistryService) - Constructor for class io.apicurio.registry.utils.serde.SchemaCache
 
self() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
serialize(String, U) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serialize(String, Headers, U) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serialize(String, T) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
 
serialize(String, Headers, T) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerializer
 
serializeData(T, U, OutputStream) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serializeData(Headers, T, U, ByteArrayOutputStream) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serializeData(Schema, U, OutputStream) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
serializeData(Headers, Schema, U, ByteArrayOutputStream) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
serializeData(byte[], U, OutputStream) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
serializeData(Headers, byte[], U, ByteArrayOutputStream) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
serializer() - Method in class io.apicurio.registry.utils.serde.AbstractSerde
 
setArtifactIdStrategy(ArtifactIdStrategy<T>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
setAvroDatumProvider(AvroDatumProvider<U>) - Method in class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
setAvroDatumProvider(AvroDatumProvider<U>) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
setGlobalIdStrategy(GlobalIdStrategy<T>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaStrategyAwareSerDe
 
setIdHandler(IdHandler) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
setKey(boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
setUseSpecificAvroReader(boolean) - Method in class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
setValidationEnabled(boolean) - Method in class io.apicurio.registry.utils.serde.JsonSchemaKafkaSerDe
 
SimpleTopicIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
SimpleTopicIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.SimpleTopicIdStrategy
 

T

toGlobalId(String, Integer) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
Converts an artifact id and version to a global id by querying the registry.
TopicIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
TopicIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.TopicIdStrategy
 
TopicRecordIdStrategy - Class in io.apicurio.registry.utils.serde.strategy
 
TopicRecordIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.TopicRecordIdStrategy
 
toSchema(Response) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
toSchema(U) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
toSchema(T) - Method in interface io.apicurio.registry.utils.serde.avro.AvroDatumProvider
 
toSchema(T) - Method in class io.apicurio.registry.utils.serde.avro.DefaultAvroDatumProvider
 
toSchema(T) - Method in class io.apicurio.registry.utils.serde.avro.ReflectAvroDatumProvider
 
toSchema(Response) - Method in class io.apicurio.registry.utils.serde.AvroKafkaDeserializer
 
toSchema(U) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
toSchema(Response) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
toSchema(U) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
toSchema(Response) - Method in class io.apicurio.registry.utils.serde.SchemaCache
 
toStream(T) - Method in interface io.apicurio.registry.utils.serde.strategy.GlobalIdStrategy
Create InputStream from schema.

U

unwrap(CompletionStage<R>) - Method in class io.apicurio.registry.utils.serde.strategy.AbstractCrudIdStrategy
 
USE_HEADERS - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
Utils - Class in io.apicurio.registry.utils.serde.util
 
Utils() - Constructor for class io.apicurio.registry.utils.serde.util.Utils
 

V

valueOf(String) - Static method in enum io.apicurio.registry.utils.serde.AvroEncoding
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.apicurio.registry.utils.serde.AvroEncoding
Returns an array containing the constants of this enum type, in the order they are declared.
versionHeaderName - Variable in class io.apicurio.registry.utils.serde.util.HeaderUtils
 

W

writeId(long, OutputStream) - Method in class io.apicurio.registry.utils.serde.strategy.DefaultIdHandler
 
writeId(long, ByteBuffer) - Method in class io.apicurio.registry.utils.serde.strategy.DefaultIdHandler
 
writeId(long, OutputStream) - Method in interface io.apicurio.registry.utils.serde.strategy.IdHandler
 
writeId(long, ByteBuffer) - Method in interface io.apicurio.registry.utils.serde.strategy.IdHandler
 
writeId(long, OutputStream) - Method in class io.apicurio.registry.utils.serde.strategy.Legacy4ByteIdHandler
 
writeId(long, ByteBuffer) - Method in class io.apicurio.registry.utils.serde.strategy.Legacy4ByteIdHandler
 
A C D E F G H I J K L M N P R S T U V W 
Skip navigation links

Copyright © 2020 Red Hat. All rights reserved.