public class ProtobufKafkaSerializer<U extends com.google.protobuf.Message> extends AbstractKafkaSerializer<byte[],U,ProtobufKafkaSerializer<U>>
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
headerUtils, key, log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_REQUEST_HEADERS_PREFIX, REGISTRY_REQUEST_KEY_PASSWORD, REGISTRY_REQUEST_KEYSTORE_LOCATION, REGISTRY_REQUEST_KEYSTORE_PASSWORD, REGISTRY_REQUEST_KEYSTORE_TYPE, REGISTRY_REQUEST_TRUSTSTORE_LOCATION, REGISTRY_REQUEST_TRUSTSTORE_PASSWORD, REGISTRY_REQUEST_TRUSTSTORE_TYPE, REGISTRY_URL_CONFIG_PARAM, USE_HEADERS
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 void |
serializeData(org.apache.kafka.common.header.Headers headers,
byte[] schema,
U data,
ByteArrayOutputStream out) |
protected byte[] |
toSchema(U data) |
serialize, serialize
configure, getArtifactIdStrategy, getGlobalIdStrategy, setArtifactIdStrategy, setGlobalIdStrategy
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
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,ProtobufKafkaSerializer<U extends com.google.protobuf.Message>>
protected io.apicurio.registry.types.ArtifactType artifactType()
artifactType
in class AbstractKafkaSerializer<byte[],U extends com.google.protobuf.Message,ProtobufKafkaSerializer<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,ProtobufKafkaSerializer<U extends com.google.protobuf.Message>>
IOException
protected void serializeData(org.apache.kafka.common.header.Headers headers, byte[] schema, U data, ByteArrayOutputStream out) throws IOException
serializeData
in class AbstractKafkaSerializer<byte[],U extends com.google.protobuf.Message,ProtobufKafkaSerializer<U extends com.google.protobuf.Message>>
IOException
Copyright © 2020 Red Hat. All rights reserved.