public abstract class AbstractKafkaDeserializer<T,U,S extends AbstractKafkaDeserializer<T,U,S>> extends AbstractKafkaSerDe<S> implements org.apache.kafka.common.serialization.Deserializer<U>
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 |
---|
AbstractKafkaDeserializer() |
AbstractKafkaDeserializer(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
U |
deserialize(String topic,
byte[] data) |
U |
deserialize(String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data) |
protected abstract U |
readData(org.apache.kafka.common.header.Headers headers,
T schema,
ByteBuffer buffer,
int start,
int length) |
protected abstract U |
readData(T schema,
ByteBuffer buffer,
int start,
int length) |
void |
reset() |
protected abstract T |
toSchema(javax.ws.rs.core.Response response) |
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, self, setIdHandler, setKey, toGlobalId
public AbstractKafkaDeserializer()
public AbstractKafkaDeserializer(RegistryService client)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Deserializer<U>
configure
in class AbstractKafkaSerDe<S extends AbstractKafkaDeserializer<T,U,S>>
public void reset()
reset
in class AbstractKafkaSerDe<S extends AbstractKafkaDeserializer<T,U,S>>
protected abstract T toSchema(javax.ws.rs.core.Response response)
protected abstract U readData(T schema, ByteBuffer buffer, int start, int length)
protected abstract U readData(org.apache.kafka.common.header.Headers headers, T schema, ByteBuffer buffer, int start, int length)
public U deserialize(String topic, byte[] data)
deserialize
in interface org.apache.kafka.common.serialization.Deserializer<U>
Copyright © 2020 Red Hat. All rights reserved.