public class SessionWindowedDeserializer<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 |
---|
SessionWindowedDeserializer() |
SessionWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner) |
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) |
public SessionWindowedDeserializer()
public SessionWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner)