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
    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)