public class ProtobufKafkaSerializer<U extends com.google.protobuf.Message> extends AbstractKafkaSerializer<byte[],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 |
---|
ProtobufKafkaSerializer() |
ProtobufKafkaSerializer(RegistryService client) |
ProtobufKafkaSerializer(RegistryService client,
ArtifactIdStrategy<byte[]> artifactIdStrategy,
GlobalIdStrategy<byte[]> idStrategy) |
Modifier and Type | Method and Description |
---|---|
protected io.apicurio.registry.types.ArtifactType |
artifactType() |
protected void |
serializeData(byte[] schema,
U data,
OutputStream out) |
protected byte[] |
toSchema(U data) |
configure, instantiate, loadClass, serialize, setArtifactIdStrategy, setGlobalIdStrategy, setKey
close, configure, getClient, isTrue, reset
public ProtobufKafkaSerializer()
public ProtobufKafkaSerializer(RegistryService client)
public ProtobufKafkaSerializer(RegistryService client, ArtifactIdStrategy<byte[]> artifactIdStrategy, GlobalIdStrategy<byte[]> idStrategy)
protected byte[] toSchema(U data)
toSchema
in class AbstractKafkaSerializer<byte[],U extends com.google.protobuf.Message>
protected io.apicurio.registry.types.ArtifactType artifactType()
artifactType
in class AbstractKafkaSerializer<byte[],U extends com.google.protobuf.Message>
protected void serializeData(byte[] schema, U data, OutputStream out) throws IOException
serializeData
in class AbstractKafkaSerializer<byte[],U extends com.google.protobuf.Message>
IOException
Copyright © 2019 Red Hat. All rights reserved.