Package io.confluent.kafka.serializers

Interface DeserializerWithSchema<T>

All Superinterfaces:

AutoCloseable, Closeable, org.apache.kafka.common.serialization.Deserializer<T>

public interface DeserializerWithSchema<T>
extends org.apache.kafka.common.serialization.Deserializer<T>

Method Summary

Modifier and Type	Method	Description
ParsedSchemaAndValue	deserializeWithSchema(String topic, org.apache.kafka.common.header.Headers headers, byte[] data)
ParsedSchemaAndValue	deserializeWithSchema(String topic, org.apache.kafka.common.header.Headers headers, byte[] data, Function<ParsedSchema,ParsedSchema> writerToReaderSchemaFunc)

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

close, configure, deserialize, deserialize, deserialize

Method Details

deserializeWithSchema

ParsedSchemaAndValue deserializeWithSchema(String topic,
 org.apache.kafka.common.header.Headers headers,
 byte[] data)

deserializeWithSchema

ParsedSchemaAndValue deserializeWithSchema(String topic,
 org.apache.kafka.common.header.Headers headers,
 byte[] data,
 Function<ParsedSchema,ParsedSchema> writerToReaderSchemaFunc)