Kafka Streams, Windowing, Kafka.
builder.stream("temperature-sensor"); TimeWindows tumblingWindows = TimeWindows.of(Duration.ofMinutes(10)); // Define a 10-minute tumbling window KTable<Windowed<String>, Double> averageTemperatures = temperatureReadings .groupByKey() // Assuming the key is the sensor ID