public abstract class AbstractKafkaStrategyAwareSerDe<T,S extends AbstractKafkaStrategyAwareSerDe<T,S>> extends AbstractKafkaSerDe<S>
Modifier and Type | Field and Description |
---|---|
static String |
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM |
static String |
REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM |
log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
Constructor and Description |
---|
AbstractKafkaStrategyAwareSerDe() |
AbstractKafkaStrategyAwareSerDe(RegistryService client) |
AbstractKafkaStrategyAwareSerDe(RegistryService client,
ArtifactIdStrategy<T> artifactIdStrategy,
GlobalIdStrategy<T> globalIdStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
protected ArtifactIdStrategy<T> |
getArtifactIdStrategy() |
protected GlobalIdStrategy<T> |
getGlobalIdStrategy() |
protected boolean |
isKey() |
S |
setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy) |
S |
setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy) |
S |
setKey(boolean key) |
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
public static final String REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM
public static final String REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
public AbstractKafkaStrategyAwareSerDe()
public AbstractKafkaStrategyAwareSerDe(RegistryService client)
public AbstractKafkaStrategyAwareSerDe(RegistryService client, ArtifactIdStrategy<T> artifactIdStrategy, GlobalIdStrategy<T> globalIdStrategy)
protected ArtifactIdStrategy<T> getArtifactIdStrategy()
protected GlobalIdStrategy<T> getGlobalIdStrategy()
protected boolean isKey()
public S setKey(boolean key)
public S setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy)
public S setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy)
Copyright © 2020 Red Hat. All rights reserved.