Kafka Streams, Windowing, Kafka.
builder.stream("clicks-topic"); // Define the sliding window TimeWindows slidingWindow = TimeWindows.of(Duration.ofMinutes(30)).advanceBy(Duration.ofMinutes(10)); // Count clicks in the sliding window KTable<Windowed<String>, Long> clickCounts = clicks .groupByKey() .windowedBy(slidingWindow)