public class TimeWindowedDeserializer<T> extends java.lang.Object implements org.apache.kafka.common.serialization.Deserializer<Windowed<T>>
StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS
or
StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS
if the no-arg constructor is called and hence it is not passed during initialization.Constructor and Description |
---|
TimeWindowedDeserializer() |
TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner) |
TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner,
long windowSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
Windowed<T> |
deserialize(java.lang.String topic,
byte[] data) |
java.lang.Long |
getWindowSize() |
void |
setIsChangelogTopic(boolean isChangelogTopic) |
public TimeWindowedDeserializer()
public TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner)
public TimeWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner, long windowSize)
public java.lang.Long getWindowSize()
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
public void close()
public void setIsChangelogTopic(boolean isChangelogTopic)