Class TimeWindowedSerializer<T>

java.lang.Object
org.apache.kafka.streams.kstream.TimeWindowedSerializer<T>
All Implemented Interfaces:
Closeable, AutoCloseable, Serializer<Windowed<T>>, org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>

public class TimeWindowedSerializer<T>
extends Object
implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
  • Constructor Details

    • TimeWindowedSerializer

      public TimeWindowedSerializer()
    • TimeWindowedSerializer

      public TimeWindowedSerializer​(Serializer<T> inner)
  • Method Details

    • configure

      public void configure​(Map<String,​?> configs, boolean isKey)
      Description copied from interface: Serializer
      Configure this class.
      Specified by:
      configure in interface Serializer<T>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value
    • serialize

      public byte[] serialize​(String topic, Windowed<T> data)
      Description copied from interface: Serializer
      Convert data into a byte array.
      Specified by:
      serialize in interface Serializer<T>
      Parameters:
      topic - topic associated with data
      data - typed data
      Returns:
      serialized bytes
    • close

      public void close()
      Description copied from interface: Serializer
      Close this serializer.

      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 Serializer<T>
    • serializeBaseKey

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