public abstract class AbstractKafkaSerDe<T extends AbstractKafkaSerDe<T>> extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
static byte |
MAGIC_BYTE |
static String |
REGISTRY_CACHED_CONFIG_PARAM |
static String |
REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM |
static String |
REGISTRY_ID_HANDLER_CONFIG_PARAM |
static String |
REGISTRY_URL_CONFIG_PARAM |
Constructor and Description |
---|
AbstractKafkaSerDe() |
AbstractKafkaSerDe(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
T |
asLegacyId() |
void |
close() |
protected void |
configure(Map<String,?> configs) |
static ByteBuffer |
getByteBuffer(byte[] payload) |
protected RegistryService |
getClient() |
IdHandler |
getIdHandler() |
protected <V> V |
instantiate(Class<V> clazz) |
protected <V> void |
instantiate(Class<V> type,
Object value,
Consumer<V> setter) |
protected <V> Class<V> |
loadClass(Class<V> type,
String className) |
void |
reset() |
protected T |
self() |
T |
setIdHandler(IdHandler idHandler) |
protected final org.slf4j.Logger log
public static final String REGISTRY_URL_CONFIG_PARAM
public static final String REGISTRY_CACHED_CONFIG_PARAM
public static final String REGISTRY_ID_HANDLER_CONFIG_PARAM
public static final String REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM
public static final byte MAGIC_BYTE
public AbstractKafkaSerDe()
public AbstractKafkaSerDe(RegistryService client)
public static ByteBuffer getByteBuffer(byte[] payload)
protected T self()
public IdHandler getIdHandler()
public T asLegacyId()
protected <V> V instantiate(Class<V> clazz)
protected RegistryService getClient()
public void reset()
public void close()
close
in interface AutoCloseable
Copyright © 2020 Red Hat. All rights reserved.