public class JsonSchemaKafkaSerDe<S extends JsonSchemaKafkaSerDe<S>> extends AbstractKafkaStrategyAwareSerDe<com.worldturner.medeia.schema.validation.SchemaValidator,S>
Modifier and Type | Field and Description |
---|---|
protected static com.worldturner.medeia.api.jackson.MedeiaJacksonApi |
api |
protected static com.fasterxml.jackson.databind.ObjectMapper |
mapper |
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, 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 |
---|
JsonSchemaKafkaSerDe()
Constructor.
|
JsonSchemaKafkaSerDe(RegistryService client,
Boolean validationEnabled)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
protected SchemaCache<com.worldturner.medeia.schema.validation.SchemaValidator> |
getSchemaCache() |
boolean |
isValidationEnabled() |
S |
setValidationEnabled(boolean validationEnabled) |
getArtifactIdStrategy, getGlobalIdStrategy, isKey, setArtifactIdStrategy, setGlobalIdStrategy, setKey
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
protected static com.worldturner.medeia.api.jackson.MedeiaJacksonApi api
protected static com.fasterxml.jackson.databind.ObjectMapper mapper
public JsonSchemaKafkaSerDe()
public JsonSchemaKafkaSerDe(RegistryService client, Boolean validationEnabled)
client
- the registry clientvalidationEnabled
- validation enabled flagpublic boolean isValidationEnabled()
public S setValidationEnabled(boolean validationEnabled)
public void configure(Map<String,?> configs, boolean isKey)
configure
in class AbstractKafkaStrategyAwareSerDe<com.worldturner.medeia.schema.validation.SchemaValidator,S extends JsonSchemaKafkaSerDe<S>>
Serializer.configure(Map, boolean)
protected SchemaCache<com.worldturner.medeia.schema.validation.SchemaValidator> getSchemaCache()
Copyright © 2020 Red Hat. All rights reserved.