THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
One remaining step is to let the TimeWindowedDeserializer be aware of the input topic type by creating a new constructor, and define a helper method in WindowedSerdes.java to return the serde back to the windowed KTable API. Below is the proposed constructor and helper method addition.
...
| Code Block |
|---|
/**
* Construct a {@code TimeWindowedSerde} object to deserialize changelog topic
* for the specified inner class type and window size.
*/
static public <T> Serde<Windowed<T>> timeWindowedSerdeFromtimeWindowedChangelogSerdeFrom(final Class<T> type, final long windowSize) {
return new TimeWindowedSerde<>(Serdes.serdeFrom(type), windowSize, true);
}
|
Compatibility, Deprecation, and Migration Plan
...