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.ByteArraySerde, Serdes.ByteBufferSerde, Serdes.BytesSerde, Serdes.DoubleSerde, Serdes.FloatSerde, Serdes.IntegerSerde, Serdes.ListSerde, Serdes.LongSerde, Serdes.ShortSerde, Serdes.StringSerde, Serdes.UUIDSerde, Serdes.VoidSerde, WindowedSerdes.SessionWindowedSerde, WindowedSerdes.TimeWindowedSerde
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>