public abstract class AbstractKafkaSerializer<T,U,S extends AbstractKafkaSerializer<T,U,S>> extends AbstractKafkaStrategyAwareSerDe<T,S> implements org.apache.kafka.common.serialization.Serializer<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 |
---|
AbstractKafkaSerializer() |
AbstractKafkaSerializer(RegistryService client) |
AbstractKafkaSerializer(RegistryService client,
ArtifactIdStrategy<T> artifactIdStrategy,
GlobalIdStrategy<T> globalIdStrategy) |
Modifier and Type | Method and Description |
---|---|
protected abstract io.apicurio.registry.types.ArtifactType |
artifactType() |
byte[] |
serialize(String topic,
org.apache.kafka.common.header.Headers headers,
U data) |
byte[] |
serialize(String topic,
U data) |
protected abstract void |
serializeData(org.apache.kafka.common.header.Headers headers,
T schema,
U data,
ByteArrayOutputStream out) |
protected abstract void |
serializeData(T schema,
U data,
OutputStream out) |
protected abstract T |
toSchema(U data) |
configure, getArtifactIdStrategy, getGlobalIdStrategy, setArtifactIdStrategy, setGlobalIdStrategy
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
public AbstractKafkaSerializer()
public AbstractKafkaSerializer(RegistryService client)
public AbstractKafkaSerializer(RegistryService client, ArtifactIdStrategy<T> artifactIdStrategy, GlobalIdStrategy<T> globalIdStrategy)
protected abstract io.apicurio.registry.types.ArtifactType artifactType()
protected abstract void serializeData(T schema, U data, OutputStream out) throws IOException
IOException
protected abstract void serializeData(org.apache.kafka.common.header.Headers headers, T schema, U data, ByteArrayOutputStream out) throws IOException
IOException
public byte[] serialize(String topic, U data)
serialize
in interface org.apache.kafka.common.serialization.Serializer<U>
Copyright © 2020 Red Hat. All rights reserved.