Kafka Streams, Windowing, Kafka.
.windowedBy(tumblingWindows) .aggregate( () -> 0.0, // Initializer (aggKey, newValue, aggValue) -> (aggValue + newValue) / 2, // Aggregator Materialized.as("average-temperatures-store") // State store name ); // Further processing or output the results to a topic } } Hopping windows Fixed-size,