public abstract class AbstractKafkaSerDe<T> extends Object
Modifier and Type | Field and Description |
---|---|
protected static int |
idSize |
protected static byte |
MAGIC_BYTE |
static String |
REGISTRY_CACHED_CONFIG_PARAM |
static String |
REGISTRY_URL_CONFIG_PARAM |
Constructor and Description |
---|
AbstractKafkaSerDe() |
AbstractKafkaSerDe(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
configure(Map<String,?> configs) |
protected RegistryService |
getClient() |
protected static boolean |
isTrue(Object cached) |
void |
reset() |
public static final String REGISTRY_URL_CONFIG_PARAM
public static final String REGISTRY_CACHED_CONFIG_PARAM
protected static final byte MAGIC_BYTE
protected static final int idSize
public AbstractKafkaSerDe()
public AbstractKafkaSerDe(RegistryService client)
protected static boolean isTrue(Object cached)
protected RegistryService getClient()
public void reset()
public void close()
Copyright © 2019 Red Hat. All rights reserved.