small fix for streams tutorial
Author: Bill Bejeck
Reviewers: Guozhang Wang
Closes from bbejeck/KAFKA_6025_fix_streams_tutorial
<pre class="brush: java;">
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
public Iterable&lt;String&gt; apply(String value) {
return Arrays.asList(value.split("\\W+"));
