Skip navigation links
A C D F G I L M P R S T 

A

AbstractKafkaDeserializer<T,U> - 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> - 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> - 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
 
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.TopicIdStrategy
 
artifactId(String, boolean, Schema) - Method in class io.apicurio.registry.utils.serde.strategy.TopicRecordIdStrategy
 
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
 
AutoRegisterIdStrategy<T> - Class in io.apicurio.registry.utils.serde.strategy
 
AutoRegisterIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.AutoRegisterIdStrategy
 
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
 
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
 

C

close() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
configure(Map<String, ?>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
configure(Map<String, ?>, boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 

D

deserialize(String, byte[]) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 

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.AutoRegisterIdStrategy
 
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
 

G

getClient() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
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.

I

idSize - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
instantiate(Class<V>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
io.apicurio.registry.utils.serde - package io.apicurio.registry.utils.serde
 
io.apicurio.registry.utils.serde.strategy - package io.apicurio.registry.utils.serde.strategy
 
isTrue(Object) - Static method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 

L

loadClass(Class<V>, String) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 

M

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

P

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
 

R

readData(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(byte[], ByteBuffer, int, int) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaDeserializer
 
RecordIdStrategy - Class in io.apicurio.registry.utils.serde.strategy
 
RecordIdStrategy() - Constructor for class io.apicurio.registry.utils.serde.strategy.RecordIdStrategy
 
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
REGISTRY_CACHED_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.AbstractKafkaSerializer
 
REGISTRY_URL_CONFIG_PARAM - Static variable in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 
reset() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaDeserializer
 
reset() - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerDe
 

S

serialize(String, U) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serializeData(T, U, OutputStream) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
serializeData(Schema, U, OutputStream) - Method in class io.apicurio.registry.utils.serde.AvroKafkaSerializer
 
serializeData(byte[], U, OutputStream) - Method in class io.apicurio.registry.utils.serde.ProtobufKafkaSerializer
 
setArtifactIdStrategy(ArtifactIdStrategy<T>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
setGlobalIdStrategy(GlobalIdStrategy<T>) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 
setKey(boolean) - Method in class io.apicurio.registry.utils.serde.AbstractKafkaSerializer
 

T

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(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
 
toStream(T) - Method in interface io.apicurio.registry.utils.serde.strategy.GlobalIdStrategy
Create InputStream from schema.
A C D F G I L M P R S T 
Skip navigation links

Copyright © 2019 Red Hat. All rights reserved.