Class SessionWindowedSerializer<T>

java.lang.Object
org.apache.kafka.streams.kstream.SessionWindowedSerializer<T>
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<Windowed<T>>, org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
public class SessionWindowedSerializer<T>extends Object implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>

  • Field Details

    • WINDOWED_INNER_SERIALIZER_CLASS

      public static final String WINDOWED_INNER_SERIALIZER_CLASS
      Default serializer for the inner serializer class of a windowed record. Must implement the Serde interface.
      See Also:

  • Constructor Details

    • SessionWindowedSerializer

      public SessionWindowedSerializer()

    • SessionWindowedSerializer

      public SessionWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner)

  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serializer<T>

    • serialize

      public byte[] serialize(String topic, Windowed<T> data)
      Specified by:
      serialize in interface org.apache.kafka.common.serialization.Serializer<T>

    • serialize

      public byte[] serialize(String topic, org.apache.kafka.common.header.Headers headers, Windowed<T> data)
      Specified by:
      serialize in interface org.apache.kafka.common.serialization.Serializer<T>

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serializer<T>

    • serializeBaseKey

      public byte[] serializeBaseKey(String topic, Windowed<T> data)
      Specified by:
      serializeBaseKey in interface org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>

    • serializeBaseKey

      public byte[] serializeBaseKey(String topic, org.apache.kafka.common.header.Headers headers, Windowed<T> data)
      Specified by:
      serializeBaseKey in interface org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>