Interface WindowedSerializer<T>

  • All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable, org.apache.kafka.common.serialization.Serializer<Windowed<T>>
    All Known Implementing Classes:
    SessionWindowedSerializer, TimeWindowedSerializer

    public interface WindowedSerializer<T>
    extends org.apache.kafka.common.serialization.Serializer<Windowed<T>>
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      byte[] serializeBaseKey​(java.lang.String topic, Windowed<T> data)  
      • Methods inherited from interface org.apache.kafka.common.serialization.Serializer

        close, configure, serialize, serialize
    • Method Detail

      • serializeBaseKey

        byte[] serializeBaseKey​(java.lang.String topic,
                                Windowed<T> data)