root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-6025: small fix for streams tutorial 

Author: Bill Bejeck <bill@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #4053 from bbejeck/KAFKA_6025_fix_streams_tutorial
This commit is contained in:
Bill Bejeck 2017-10-10 15:07:53 -07:00 committed by Guozhang Wang
parent 1027ff3c76
commit dac990aab3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/streams/tutorial.html
View File

@ -337,7 +337,7 @@
<pre class="brush: java;"> <pre class="brush: java;">
KStream&lt;String, String&gt; source = builder.stream("streams-plaintext-input"); KStream&lt;String, String&gt; source = builder.stream("streams-plaintext-input");
KStream&lt;String, String&gt; words = builder.flatMapValues(new ValueMapper&lt;String, Iterable&lt;String&gt;&gt;() { KStream&lt;String, String&gt; words = source.flatMapValues(new ValueMapper&lt;String, Iterable&lt;String&gt;&gt;() {
@Override @Override
public Iterable&lt;String&gt; apply(String value) { public Iterable&lt;String&gt; apply(String value) {
return Arrays.asList(value.split("\\W+")); return Arrays.asList(value.split("\\W+"));