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 |
headerUtils, key, log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_REQUEST_HEADERS_PREFIX, REGISTRY_REQUEST_KEY_PASSWORD, REGISTRY_REQUEST_KEYSTORE_LOCATION, REGISTRY_REQUEST_KEYSTORE_PASSWORD, REGISTRY_REQUEST_KEYSTORE_TYPE, REGISTRY_REQUEST_TRUSTSTORE_LOCATION, REGISTRY_REQUEST_TRUSTSTORE_PASSWORD, REGISTRY_REQUEST_TRUSTSTORE_TYPE, REGISTRY_URL_CONFIG_PARAM, USE_HEADERS
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() |
S |
setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy) |
S |
setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy) |
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
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()
public S setArtifactIdStrategy(ArtifactIdStrategy<T> artifactIdStrategy)
public S setGlobalIdStrategy(GlobalIdStrategy<T> globalIdStrategy)
public void configure(Map<String,?> configs, boolean isKey)
configure
in class AbstractKafkaSerDe<S extends AbstractKafkaStrategyAwareSerDe<T,S>>
Copyright © 2020 Red Hat. All rights reserved.