Kafka Streams, Windowing, Kafka.
builder.stream("page-views"); TimeWindows hoppingWindows = TimeWindows.of(Duration.ofMinutes(5)) // Window size .advanceBy(Duration.ofMinutes(1)); // Advance interval KTable<Windowed<String>, Long> pageViewCounts = pageViews .groupBy((key, value) -> value) // Group by page view event value (or some