public static class WindowedSerdes.TimeWindowedSerde<T> extends org.apache.kafka.common.serialization.Serdes.WrapperSerde<Windowed<T>>
| Constructor and Description |
|---|
TimeWindowedSerde() |
TimeWindowedSerde(org.apache.kafka.common.serialization.Serde<T> inner)Deprecated. |
TimeWindowedSerde(org.apache.kafka.common.serialization.Serde<T> inner, long windowSize) |
| Modifier and Type | Method and Description |
|---|---|
WindowedSerdes.TimeWindowedSerde<T> | forChangelog(boolean isChangelogTopic) |
public TimeWindowedSerde()
@Deprecated public TimeWindowedSerde(org.apache.kafka.common.serialization.Serde<T> inner)
public TimeWindowedSerde(org.apache.kafka.common.serialization.Serde<T> inner, long windowSize)
public WindowedSerdes.TimeWindowedSerde<T> forChangelog(boolean isChangelogTopic)