public abstract class AbstractKafkaDeserializer<T,U,S extends AbstractKafkaDeserializer<T,U,S>> extends AbstractKafkaSerDe<S> implements org.apache.kafka.common.serialization.Deserializer<U>
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 |
---|
AbstractKafkaDeserializer() |
AbstractKafkaDeserializer(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
U |
deserialize(String topic,
byte[] data) |
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, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, self, setIdHandler
public AbstractKafkaDeserializer()
public AbstractKafkaDeserializer(RegistryService client)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Deserializer<U>
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)
Copyright © 2020 Red Hat. All rights reserved.