public class AvroKafkaDeserializer<U> extends AbstractKafkaDeserializer<org.apache.avro.Schema,U,AvroKafkaDeserializer<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 |
---|
AvroKafkaDeserializer() |
AvroKafkaDeserializer(RegistryService client) |
AvroKafkaDeserializer(RegistryService client,
AvroDatumProvider<U> avroDatumProvider) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
protected U |
readData(org.apache.avro.Schema schema,
ByteBuffer buffer,
int start,
int length) |
AvroKafkaDeserializer<U> |
setAvroDatumProvider(AvroDatumProvider<U> avroDatumProvider) |
protected org.apache.avro.Schema |
toSchema(javax.ws.rs.core.Response response) |
deserialize, reset
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, self, setIdHandler
public AvroKafkaDeserializer()
public AvroKafkaDeserializer(RegistryService client)
public AvroKafkaDeserializer(RegistryService client, AvroDatumProvider<U> avroDatumProvider)
public AvroKafkaDeserializer<U> setAvroDatumProvider(AvroDatumProvider<U> avroDatumProvider)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Deserializer<U>
configure
in class AbstractKafkaDeserializer<org.apache.avro.Schema,U,AvroKafkaDeserializer<U>>
protected org.apache.avro.Schema toSchema(javax.ws.rs.core.Response response)
toSchema
in class AbstractKafkaDeserializer<org.apache.avro.Schema,U,AvroKafkaDeserializer<U>>
protected U readData(org.apache.avro.Schema schema, ByteBuffer buffer, int start, int length)
readData
in class AbstractKafkaDeserializer<org.apache.avro.Schema,U,AvroKafkaDeserializer<U>>
Copyright © 2020 Red Hat. All rights reserved.