Fix Kafka Streams example in the documentation (#3282)

spring-projects · May 28, 2024 · c65ce27 · c65ce27
1 parent af26d9b
commit c65ce27
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/streams.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/streams.adoc
@@ -473,7 +473,7 @@ public class KafkaStreamsConfig {
         stream
                 .mapValues((ValueMapper<String, String>) String::toUpperCase)
                 .groupByKey()
-                .windowedBy(TimeWindows.of(Duration.ofMillis(1_000)))
+                .windowedBy(TimeWindows.ofSizeWithNoGrace(Duration.ofMillis(1_000)))
                 .reduce((String value1, String value2) -> value1 + value2,
                 		Named.as("windowStore"))
                 .toStream()