Package org.apache.kafka.streams.kstream.internals

Interface WindowedSerializer<T>

All Superinterfaces:

AutoCloseable, Closeable, Serializer<Windowed<T>>

All Known Implementing Classes:

SessionWindowedSerializer, TimeWindowedSerializer

public interface WindowedSerializer<T>
extends Serializer<Windowed<T>>

Method Summary

Modifier and Type	Method	Description
byte[]	serializeBaseKey(String topic, Windowed<T> data)

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

close, configure, serialize, serialize

Method Detail

serializeBaseKey

byte[] serializeBaseKey(String topic,
                        Windowed<T> data)