public class ProtobufKafkaDeserializer extends AbstractKafkaDeserializer<byte[],com.google.protobuf.DynamicMessage,ProtobufKafkaDeserializer>
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 |
---|
ProtobufKafkaDeserializer() |
ProtobufKafkaDeserializer(RegistryService client) |
Modifier and Type | Method and Description |
---|---|
protected com.google.protobuf.DynamicMessage |
readData(byte[] schema,
ByteBuffer buffer,
int start,
int length) |
protected byte[] |
toSchema(javax.ws.rs.core.Response response) |
configure, deserialize, reset
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, self, setIdHandler
public ProtobufKafkaDeserializer()
public ProtobufKafkaDeserializer(RegistryService client)
protected byte[] toSchema(javax.ws.rs.core.Response response)
toSchema
in class AbstractKafkaDeserializer<byte[],com.google.protobuf.DynamicMessage,ProtobufKafkaDeserializer>
protected com.google.protobuf.DynamicMessage readData(byte[] schema, ByteBuffer buffer, int start, int length)
readData
in class AbstractKafkaDeserializer<byte[],com.google.protobuf.DynamicMessage,ProtobufKafkaDeserializer>
Copyright © 2020 Red Hat. All rights reserved.