Interface UberSerde<T>

All Superinterfaces:
AutoCloseable, Closeable, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, SerdeWithJson<T>, org.apache.kafka.common.serialization.Serializer<T>
All Known Subinterfaces:
OrderedKeyPrefixedSerde<E,T>, OrderedKeyUberSerde<T>
All Known Implementing Classes:
OrderedKeyPrefixedProtoSerde, OrderedKeyProtoSerde, OrderedKeyUberSerdeDelegate, ProtoSerde, StringSerde, UberSerdes.DelegatingUberSerde
public interface UberSerde<T> extends SerdeWithJson<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final byte
    MAGIC_BYTE_ORDERED_KEY
     
    static final byte
    MAGIC_BYTE_PROTOBUF
     
    static final byte
    MAGIC_BYTE_STRING
     

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    close()
    Close this deserializer.
    default void
    configure(Map<String,?> configs, boolean isKey)
    Configure this class, which will configure the underlying serializer and deserializer.
    Class<T>
    type()
     

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

    deserialize, deserialize, deserialize

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

    deserializer, serializer

    Methods inherited from interface SerdeWithJson

    deserialize, fromJson, serialize, toJson

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

    serialize, serialize

  • Field Details

  • Method Details

    • type

      Class<T> type()

    • configure

      default void configure(Map<String,?> configs, boolean isKey)
      Configure this class, which will configure the underlying serializer and deserializer.
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Deserializer<T>
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serde<T>
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serializer<T>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value

    • close

      default void close()
      Close this deserializer.

      This method must be idempotent as it may be called multiple times.

      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.common.serialization.Deserializer<T>
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serde<T>
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serializer<T>