Repository: kafka Updated Branches: refs/heads/trunk 1027ff3c7 -> dac990aab
KAFKA-6025: small fix for streams tutorial Author: Bill Bejeck <b...@confluent.io> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #4053 from bbejeck/KAFKA_6025_fix_streams_tutorial Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/dac990aa Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/dac990aa Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/dac990aa Branch: refs/heads/trunk Commit: dac990aab31ab13ed08a6818e1516f4dd25331dd Parents: 1027ff3 Author: Bill Bejeck <b...@confluent.io> Authored: Tue Oct 10 15:07:53 2017 -0700 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Tue Oct 10 15:07:53 2017 -0700 ---------------------------------------------------------------------- docs/streams/tutorial.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/dac990aa/docs/streams/tutorial.html ---------------------------------------------------------------------- diff --git a/docs/streams/tutorial.html b/docs/streams/tutorial.html index b93ba6f..ec41a93 100644 --- a/docs/streams/tutorial.html +++ b/docs/streams/tutorial.html @@ -337,7 +337,7 @@ <pre class="brush: java;"> KStream<String, String> source = builder.stream("streams-plaintext-input"); - KStream<String, String> words = builder.flatMapValues(new ValueMapper<String, Iterable<String>>() { + KStream<String, String> words = source.flatMapValues(new ValueMapper<String, Iterable<String>>() { @Override public Iterable<String> apply(String value) { return Arrays.asList(value.split("\\W+"));