Package io.confluent.kafka.serializers

Interface SerializerWithSchema<T>

All Superinterfaces:
AutoCloseable, Closeable, org.apache.kafka.common.serialization.Serializer<T>
public interface SerializerWithSchema<T> extends org.apache.kafka.common.serialization.Serializer<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    serialize(String topic, org.apache.kafka.common.header.Headers headers, T data, ParsedSchema schema)
     

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

    close, configure, serialize, serialize

  • Method Details

    • serialize

      byte[] serialize(String topic, org.apache.kafka.common.header.Headers headers, T data, ParsedSchema schema)