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)
     

    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)