public class ProtobufKafkaDeserializer extends AbstractKafkaDeserializer<byte[],com.google.protobuf.DynamicMessage,ProtobufKafkaDeserializer>
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 |
---|
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 com.google.protobuf.DynamicMessage |
readData(org.apache.kafka.common.header.Headers headers,
byte[] schema,
ByteBuffer buffer,
int start,
int length) |
protected byte[] |
toSchema(javax.ws.rs.core.Response response) |
configure, deserialize, deserialize, reset
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, self, setIdHandler, setKey, toGlobalId
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>
protected com.google.protobuf.DynamicMessage readData(org.apache.kafka.common.header.Headers headers, 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.