public class AvroKafkaDeserializer<U> extends AbstractKafkaDeserializer<org.apache.avro.Schema,U>
idSize, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
Constructor and Description |
---|
AvroKafkaDeserializer() |
AvroKafkaDeserializer(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
protected U |
readData(org.apache.avro.Schema schema,
ByteBuffer buffer,
int start,
int length) |
protected org.apache.avro.Schema |
toSchema(javax.ws.rs.core.Response response) |
configure, deserialize, reset
close, configure, getClient, isTrue
public AvroKafkaDeserializer()
public AvroKafkaDeserializer(RegistryService client)
protected org.apache.avro.Schema toSchema(javax.ws.rs.core.Response response)
toSchema
in class AbstractKafkaDeserializer<org.apache.avro.Schema,U>
protected U readData(org.apache.avro.Schema schema, ByteBuffer buffer, int start, int length)
readData
in class AbstractKafkaDeserializer<org.apache.avro.Schema,U>
Copyright © 2019 Red Hat. All rights reserved.