Kafka stream how to test a sliding window?

I have a test that test a sliding window like this : .groupByKey .windowedBy { TimeWindows.of(Duration.ofMinutes(10)) .advanceBy(Duration.ofMinutes(1)).grace(Duration.ofMillis(0)) } .aggregate(…) .suppress(Suppressed.untilWindowCloses(unbounded())) I need to test that the sliding window produce the right output after a step. I did something like this : for (i <- 0 to 8) testDriver.pipeInput(record…, T0 to T8)// produce one record every…

Details