public class TimeWindowedDeserializer<T> extends Object implements org.apache.kafka.common.serialization.Deserializer<Windowed<T>>
| Constructor and Description |
|---|
TimeWindowedDeserializer() |
TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner)Deprecated. |
TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner, Long windowSize) |
| Modifier and Type | Method and Description |
|---|---|
void | close() |
void | configure(Map<String,?> configs, boolean isKey) |
Windowed<T> | deserialize(String topic, byte[] data) |
Long | getWindowSize() |
void | setIsChangelogTopic(boolean isChangelogTopic) |
public TimeWindowedDeserializer()
@Deprecated public TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner)