public abstract class AbstractKafkaSerDe<T extends AbstractKafkaSerDe<T>> extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
protected HeaderUtils |
headerUtils |
protected boolean |
key |
protected org.slf4j.Logger |
log |
static byte |
MAGIC_BYTE |
static String |
REGISTRY_CACHED_CONFIG_PARAM
Deprecated.
|
static String |
REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM |
static String |
REGISTRY_ID_HANDLER_CONFIG_PARAM |
static String |
REGISTRY_REQUEST_HEADERS_PREFIX |
static String |
REGISTRY_REQUEST_KEY_PASSWORD |
static String |
REGISTRY_REQUEST_KEYSTORE_LOCATION |
static String |
REGISTRY_REQUEST_KEYSTORE_PASSWORD |
static String |
REGISTRY_REQUEST_KEYSTORE_TYPE |
static String |
REGISTRY_REQUEST_TRUSTSTORE_LOCATION |
static String |
REGISTRY_REQUEST_TRUSTSTORE_PASSWORD |
static String |
REGISTRY_REQUEST_TRUSTSTORE_TYPE |
static String |
REGISTRY_URL_CONFIG_PARAM |
static String |
USE_HEADERS |
Constructor and Description |
---|
AbstractKafkaSerDe() |
AbstractKafkaSerDe(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
T |
asLegacyId() |
void |
close() |
protected void |
configure(Map<String,?> configs,
boolean isKey) |
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 boolean |
isKey() |
protected <V> Class<V> |
loadClass(Class<V> type,
String className) |
void |
reset() |
protected T |
self() |
T |
setIdHandler(IdHandler idHandler) |
Object |
setKey(boolean key) |
protected Long |
toGlobalId(String artifactId,
Integer version)
Converts an artifact id and version to a global id by querying the registry.
|
protected final org.slf4j.Logger log
public static final String REGISTRY_URL_CONFIG_PARAM
@Deprecated 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 String USE_HEADERS
public static final String REGISTRY_REQUEST_HEADERS_PREFIX
public static final String REGISTRY_REQUEST_TRUSTSTORE_LOCATION
public static final String REGISTRY_REQUEST_TRUSTSTORE_TYPE
public static final String REGISTRY_REQUEST_TRUSTSTORE_PASSWORD
public static final String REGISTRY_REQUEST_KEYSTORE_LOCATION
public static final String REGISTRY_REQUEST_KEYSTORE_TYPE
public static final String REGISTRY_REQUEST_KEYSTORE_PASSWORD
public static final String REGISTRY_REQUEST_KEY_PASSWORD
public static final byte MAGIC_BYTE
protected boolean key
protected HeaderUtils headerUtils
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
protected boolean isKey()
public Object setKey(boolean key)
Copyright © 2020 Red Hat. All rights reserved.