Class SessionWindowedSerializer<T>

    • Constructor Detail

      • SessionWindowedSerializer

        public SessionWindowedSerializer()
      • SessionWindowedSerializer

        public SessionWindowedSerializer​(Serializer<T> inner)
    • Method Detail

      • 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>