diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/docs/src/main/asciidoc/kafka-streams.adoc index fcbd50e69..1b8ec4bad 100644 --- a/docs/src/main/asciidoc/kafka-streams.adoc +++ b/docs/src/main/asciidoc/kafka-streams.adoc @@ -448,7 +448,7 @@ public static class WordCountProcessorApplication { private TimeWindows timeWindows; @StreamListener("input") - @SendTo({"output1","output2","output3}) + @SendTo({"output1","output2","output3"}) public KStream[] process(KStream input) { Predicate isEnglish = (k, v) -> v.word.equals("english");