From 0689e87489595914f36d0183ff8433933245f3c9 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 4 Apr 2018 11:25:18 -0400 Subject: [PATCH] Polishing kafka streams docs --- .../src/main/asciidoc/kafka-streams.adoc | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-cloud-stream-binder-kafka-docs/src/main/asciidoc/kafka-streams.adoc b/spring-cloud-stream-binder-kafka-docs/src/main/asciidoc/kafka-streams.adoc index e96bee9f3..b0b8e284d 100644 --- a/spring-cloud-stream-binder-kafka-docs/src/main/asciidoc/kafka-streams.adoc +++ b/spring-cloud-stream-binder-kafka-docs/src/main/asciidoc/kafka-streams.adoc @@ -169,7 +169,7 @@ spring.cloud.stream.kafka.streams.timeWindow.length:: The value is expressed in milliseconds. + Default: `none`. -spring.cloud.stream.kstream.timeWindow.advanceBy:: +spring.cloud.stream.kafka.streams.timeWindow.advanceBy:: Value is given in milliseconds. + Default: `none`. @@ -413,9 +413,9 @@ If `nativeEncoding` is set, then you can set different SerDe's on individual out [source] ---- -spring.cloud.stream.kstream.bindings.output1.producer.valueSerde=IntegerSerde -spring.cloud.stream.kstream.bindings.output2.producer.valueSerde=StringSerde -spring.cloud.stream.kstream.bindings.output3.producer.valueSerde=JsonSerde +spring.cloud.stream.kafka.streams.bindings.output1.producer.valueSerde=IntegerSerde +spring.cloud.stream.kafka.streams.bindings.output2.producer.valueSerde=StringSerde +spring.cloud.stream.kafka.streams.bindings.output3.producer.valueSerde=JsonSerde ---- Then if you have `SendTo` like this, @SendTo({"output1", "output2", "output3"}), the `KStream[]` from the branches are