[kafka-site] branch asf-site updated: MINOR: fix tutorial example code snippet

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git


The following commit(s) were added to refs/heads/asf-site by this push:
     new 3940fa0  MINOR: fix tutorial example code snippet
3940fa0 is described below

commit 3940fa031ddffbad88aad4491a98599c745cf3ce
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Fri May 4 09:58:31 2018 -0700

    MINOR: fix tutorial example code snippet
---
 10/streams/tutorial.html | 2 +-
 11/streams/tutorial.html | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/10/streams/tutorial.html b/10/streams/tutorial.html
index 11162e8..0bad0e5 100644
--- a/10/streams/tutorial.html
+++ b/10/streams/tutorial.html
@@ -532,7 +532,7 @@
               .groupBy((key, value) -> value)
               .count(Materialized.&lt;String, Long, KeyValueStore&lt;Bytes, byte[]&gt;&gt;as("counts-store"))
               .toStream()
-              .to("streams-wordcount-output", Produced.with(Serdes.String(), Serdes.Long());
+              .to("streams-wordcount-output", Produced.with(Serdes.String(), Serdes.Long()));
     </pre>
 
     <p>
diff --git a/11/streams/tutorial.html b/11/streams/tutorial.html
index f390b6d..21ff030 100644
--- a/11/streams/tutorial.html
+++ b/11/streams/tutorial.html
@@ -532,7 +532,7 @@
               .groupBy((key, value) -> value)
               .count(Materialized.&lt;String, Long, KeyValueStore&lt;Bytes, byte[]&gt;&gt;as("counts-store"))
               .toStream()
-              .to("streams-wordcount-output", Produced.with(Serdes.String(), Serdes.Long());
+              .to("streams-wordcount-output", Produced.with(Serdes.String(), Serdes.Long()));
     </pre>
 
     <p>

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.