public abstract class AbstractKafkaSerializer<T,U> extends AbstractKafkaSerDe<T> implements org.apache.kafka.common.serialization.Serializer<U>
Modifier and Type | Field and Description |
---|---|
static String |
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM |
static String |
REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM |
idSize, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
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() |
void |
configure(Map<String,?> configs,
boolean isKey) |
protected <V> V |
instantiate(Class<V> clazz) |
protected <V> Class<V> |
loadClass(Class<V> type,
String className) |
byte[] |
serialize(String topic,
U data) |
protected abstract void |
serializeData(T schema,
U data,
OutputStream out) |
AbstractKafkaSerializer<T,U> |
setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy) |
AbstractKafkaSerializer<T,U> |
setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy) |
AbstractKafkaSerializer<T,U> |
setKey(boolean key) |
protected abstract T |
toSchema(U data) |
close, configure, getClient, isTrue, reset
public static final String REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM
public static final String REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
public AbstractKafkaSerializer()
public AbstractKafkaSerializer(RegistryService client)
public AbstractKafkaSerializer(RegistryService client, ArtifactIdStrategy<T> artifactIdStrategy, GlobalIdStrategy<T> globalIdStrategy)
public AbstractKafkaSerializer<T,U> setKey(boolean key)
public AbstractKafkaSerializer<T,U> setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy)
public AbstractKafkaSerializer<T,U> setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Serializer<U>
protected <V> V instantiate(Class<V> clazz)
protected abstract io.apicurio.registry.types.ArtifactType artifactType()
protected abstract void serializeData(T schema, U data, OutputStream out) throws IOException
IOException
Copyright © 2019 Red Hat. All rights reserved.