Package | Description |
---|---|
io.apicurio.registry.utils.serde | |
io.apicurio.registry.utils.serde.strategy |
Modifier and Type | Method and Description |
---|---|
protected GlobalIdStrategy<T> |
AbstractKafkaStrategyAwareSerDe.getGlobalIdStrategy() |
Modifier and Type | Method and Description |
---|---|
S |
AbstractKafkaStrategyAwareSerDe.setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy) |
Constructor and Description |
---|
AbstractKafkaSerializer(RegistryService client,
ArtifactIdStrategy<T> artifactIdStrategy,
GlobalIdStrategy<T> globalIdStrategy) |
AbstractKafkaStrategyAwareSerDe(RegistryService client,
ArtifactIdStrategy<T> artifactIdStrategy,
GlobalIdStrategy<T> globalIdStrategy) |
AvroKafkaSerializer(RegistryService client,
ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy,
GlobalIdStrategy<org.apache.avro.Schema> idStrategy) |
AvroKafkaSerializer(RegistryService client,
ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy,
GlobalIdStrategy<org.apache.avro.Schema> globalIdStrategy,
AvroDatumProvider<U> avroDatumProvider) |
ProtobufKafkaSerializer(RegistryService client,
ArtifactIdStrategy<byte[]> artifactIdStrategy,
GlobalIdStrategy<byte[]> idStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCrudIdStrategy<T> |
class |
AutoRegisterIdStrategy<T> |
class |
CachedSchemaIdStrategy<T>
We first check client-side cache for matching schema,
if none matches, we check server-side,
create new if none matches (and cache it).
|
class |
FindBySchemaIdStrategy<T> |
class |
FindLatestIdStrategy<T> |
class |
GetOrCreateIdStrategy<T> |
Copyright © 2020 Red Hat. All rights reserved.