public class JsonSchemaKafkaDeserializer<T> extends JsonSchemaKafkaSerDe<JsonSchemaKafkaDeserializer<T>> implements org.apache.kafka.common.serialization.Deserializer<T>
api, 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 |
---|
JsonSchemaKafkaDeserializer()
Constructor.
|
JsonSchemaKafkaDeserializer(RegistryService client,
Boolean validationEnabled)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
T |
deserialize(String topic,
byte[] data) |
T |
deserialize(String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data) |
protected String |
getArtifactId(org.apache.kafka.common.header.Headers headers)
Gets the artifact id from the headers.
|
protected Long |
getGlobalId(org.apache.kafka.common.header.Headers headers)
Gets the global id from the headers.
|
protected Class<T> |
getMessageType(org.apache.kafka.common.header.Headers headers)
Gets the message type from the headers.
|
protected Integer |
getVersion(org.apache.kafka.common.header.Headers headers)
Gets the artifact version from the headers.
|
protected Long |
toGlobalId(String artifactId,
Integer version)
Converts an artifact id and version to a global id by querying the registry.
|
configure, getSchemaCache, isValidationEnabled, setValidationEnabled
getArtifactIdStrategy, getGlobalIdStrategy, isKey, setArtifactIdStrategy, setGlobalIdStrategy, setKey
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
public JsonSchemaKafkaDeserializer()
public JsonSchemaKafkaDeserializer(RegistryService client, Boolean validationEnabled)
public T deserialize(String topic, byte[] data)
deserialize
in interface org.apache.kafka.common.serialization.Deserializer<T>
Deserializer.deserialize(java.lang.String, byte[])
public T deserialize(String topic, org.apache.kafka.common.header.Headers headers, byte[] data)
deserialize
in interface org.apache.kafka.common.serialization.Deserializer<T>
Deserializer.deserialize(java.lang.String, org.apache.kafka.common.header.Headers, byte[])
protected Long getGlobalId(org.apache.kafka.common.header.Headers headers)
headers
- the headersprotected String getArtifactId(org.apache.kafka.common.header.Headers headers)
headers
- the headersprotected Integer getVersion(org.apache.kafka.common.header.Headers headers)
headers
- the headersprotected Class<T> getMessageType(org.apache.kafka.common.header.Headers headers)
headers
- the headersCopyright © 2020 Red Hat. All rights reserved.