Fix typo

2019-12-02 18:17:41 +09:00
parent 88c5aa0969
commit 4b50f7c2f5
1 changed files with 1 additions and 1 deletions
--- 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<?, WordCount>[] process(KStream<Object, String> input) {

 			Predicate<Object, WordCount> isEnglish = (k, v) -> v.word.equals("english");