Versions Compared

Old Version 7

changes.mady.by.user Leah Thomas

Saved on

compared with

New Version 8

changes.mady.by.user Leah Thomas

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Add window.size.ms to the ConsumerConfigs class to ensure that the desired window size is set when the consumer creates the TimeWindowedDeserializer instance. This is relevant for consuming TimeWindowed records directly, which is particularly helpful for when testing windowed aggregations. Without this change, all windows will have a size and end time of Long.MAX_VALUE.

...