public class TimeWindowedSerializer<T> extends Object implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
| Constructor and Description |
|---|
TimeWindowedSerializer() |
TimeWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner) |
| Modifier and Type | Method and Description |
|---|---|
void | close() |
void | configure(Map<String,?> configs, boolean isKey) |
byte[] | serialize(String topic, Windowed<T> data) |
byte[] | serializeBaseKey(String topic, Windowed<T> data) |
public TimeWindowedSerializer()
public TimeWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner)