-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
Current version is 3.0.1
CP 3.1 should be release the next weeks
So CP 3.2 should be there is about 4 month (Kafka follows a time base
release cycle of 4 month and CP usually aligns with Kafka releases)
- -Matthias
On 10/20/16 5:10 PM, Mohit Anch
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
Hi,
you can set window retention time via method Windows#until() (and this
retention time is based on the timestamps returned from you custom
timestamp extractor). This keeps all windows until the retention time
passes and thus, all later arrival re
