Description
Can be integration or system test.
The idea is to test with tighter time bounds with windows of say 30 seconds and use system time without adding any extra time for verification.
Currently, all the tests rely on artificially advancing system time, which should be reliable, but you never know. So, we want to add a test that works exactly like production code.
Attachments
Issue Links
- is depended upon by
-
KAFKA-8080 Remove streams_eos_test system test
-
- Open
-
- relates to
-
KAFKA-7895 Ktable supress operator emitting more than one record for the same key per window
-
- Resolved
-
- links to