public class AvroKafkaSerializer<U> extends AbstractKafkaSerializer<org.apache.avro.Schema,U>
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
idSize, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
Constructor and Description |
---|
AvroKafkaSerializer() |
AvroKafkaSerializer(RegistryService client) |
AvroKafkaSerializer(RegistryService client,
ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy,
GlobalIdStrategy<org.apache.avro.Schema> idStrategy) |
Modifier and Type | Method and Description |
---|---|
protected io.apicurio.registry.types.ArtifactType |
artifactType() |
protected void |
serializeData(org.apache.avro.Schema schema,
U data,
OutputStream out) |
protected org.apache.avro.Schema |
toSchema(U data) |
configure, instantiate, loadClass, serialize, setArtifactIdStrategy, setGlobalIdStrategy, setKey
close, configure, getClient, isTrue, reset
public AvroKafkaSerializer()
public AvroKafkaSerializer(RegistryService client)
public AvroKafkaSerializer(RegistryService client, ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy, GlobalIdStrategy<org.apache.avro.Schema> idStrategy)
protected org.apache.avro.Schema toSchema(U data)
toSchema
in class AbstractKafkaSerializer<org.apache.avro.Schema,U>
protected io.apicurio.registry.types.ArtifactType artifactType()
artifactType
in class AbstractKafkaSerializer<org.apache.avro.Schema,U>
protected void serializeData(org.apache.avro.Schema schema, U data, OutputStream out) throws IOException
serializeData
in class AbstractKafkaSerializer<org.apache.avro.Schema,U>
IOException
Copyright © 2019 Red Hat. All rights reserved.