Package org.apache.kafka.streams.kstream

Class TimeWindowedDeserializer<T>

java.lang.Object
org.apache.kafka.streams.kstream.TimeWindowedDeserializer<T>
All Implemented Interfaces:
Closeable, AutoCloseable, Deserializer<Windowed<T>>
public class TimeWindowedDeserializer<T> extends Object implements Deserializer<Windowed<T>>

  • Constructor Details

    • TimeWindowedDeserializer

      public TimeWindowedDeserializer()

    • TimeWindowedDeserializer

      @Deprecated public TimeWindowedDeserializer(Deserializer<T> inner)
      Deprecated.

    • TimeWindowedDeserializer

      public TimeWindowedDeserializer(Deserializer<T> inner, Long windowSize)

  • Method Details

    • getWindowSize

      public Long getWindowSize()

    • configure

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

    • deserialize

      public Windowed<T> deserialize(String topic, byte[] data)
      Description copied from interface: Deserializer
      Deserialize a record value from a byte array into a value or object.
      Specified by:
      deserialize in interface Deserializer<T>
      Parameters:
      topic - topic associated with the data
      data - serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.
      Returns:
      deserialized typed data; may be null

    • close

      public void close()
      Description copied from interface: Deserializer
      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 Deserializer<T>

    • setIsChangelogTopic

      public void setIsChangelogTopic(boolean isChangelogTopic)