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
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 |
---|
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.
|
configure, getSchemaCache, isValidationEnabled, setValidationEnabled
getArtifactIdStrategy, getGlobalIdStrategy, setArtifactIdStrategy, setGlobalIdStrategy
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
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 headersCopyright © 2020 Red Hat. All rights reserved.