Skip to content

Commit c65ce27

Browse files
authored
Fix Kafka Streams example in the documentation (#3282)
1 parent af26d9b commit c65ce27

File tree

1 file changed

+1
-1
lines changed
  • spring-kafka-docs/src/main/antora/modules/ROOT/pages

1 file changed

+1
-1
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/streams.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -473,7 +473,7 @@ public class KafkaStreamsConfig {
473473
stream
474474
.mapValues((ValueMapper<String, String>) String::toUpperCase)
475475
.groupByKey()
476-
.windowedBy(TimeWindows.of(Duration.ofMillis(1_000)))
476+
.windowedBy(TimeWindows.ofSizeWithNoGrace(Duration.ofMillis(1_000)))
477477
.reduce((String value1, String value2) -> value1 + value2,
478478
Named.as("windowStore"))
479479
.toStream()

0 commit comments

Comments
 (0)