THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
In StreamsConfig.java add default.window.size.ms
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/** <code>window<code>default.window.size.ms</code> */ public static final String DEFAULT_WINDOW_SIZE_MS_CONFIG = "window.size.ms"; private static final String DEFAULT_WINDOW_SIZE_MS_DOC = "Passes window size to the deserializer in order to calculate window end times. Default is Long.MAX_VALUE"; |
...
Code Block | ||||
---|---|---|---|---|
| ||||
// Log error message and pass through to underlying deserializer implicit def timeWindowedSerde[T](implicit tSerde: Serde[T]): WindowedSerdes.TimeWindowedSerde[T] = new WindowedSerdes.TimeWindowedSerde[T](tSerde) |
Proposed Changes
Add default.window.size.ms to the StreamsConfigs class to ensure that the desired window size is set when the consumer creates the TimeWindowedDeserializer instance. The default value for this config is Long.MAX_VALUE. This is relevant for consuming TimeWindowed records directly, which is helpful when testing windowed aggregations. Without this change, all windows will have a size and end time of Long.MAX_VALUE.
...