Class Serdes.WrapperSerde<T>

java.lang.Object
org.apache.kafka.common.serialization.Serdes.WrapperSerde<T>
All Implemented Interfaces:
Closeable, AutoCloseable, Serde<T>
Direct Known Subclasses:
Serdes.BooleanSerde, Serdes.ByteArraySerde, Serdes.ByteBufferSerde, Serdes.BytesSerde, Serdes.DoubleSerde, Serdes.FloatSerde, Serdes.IntegerSerde, Serdes.ListSerde, Serdes.LongSerde, Serdes.ShortSerde, Serdes.StringSerde, Serdes.UUIDSerde, Serdes.VoidSerde
Enclosing class:
Serdes
public static class Serdes.WrapperSerde<T> extends Object implements Serde<T>

  • Constructor Details

  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Description copied from interface: Serde
      Configure this class, which will configure the underlying serializer and deserializer.
      Specified by:
      configure in interface Serde<T>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value

    • close

      public void close()
      Description copied from interface: Serde
      Close this serde class, which will close the underlying serializer and deserializer.

      This method has to be idempotent because it might be called multiple times.

      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface Serde<T>

    • serializer

      public Serializer<T> serializer()
      Specified by:
      serializer in interface Serde<T>

    • deserializer

      public Deserializer<T> deserializer()
      Specified by:
      deserializer in interface Serde<T>