Repository: kafka Updated Branches: refs/heads/1.0 fbbfc2bc0 -> 43dda72f6
MINOR: Update JavaDoc to use new API Author: Bill Bejeck <[email protected]> Reviewers: Guozhang Wang <[email protected]>, Matthias J. Sax<[email protected]> Closes #4068 from bbejeck/MINOR_fix_java_doc_example_for_1_0_API (cherry picked from commit 31fe1f98e2f19074360e85c8ec839356238f0b29) Signed-off-by: Guozhang Wang <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/43dda72f Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/43dda72f Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/43dda72f Branch: refs/heads/1.0 Commit: 43dda72f670423b2f28a572fb6c089951dccb210 Parents: fbbfc2b Author: Bill Bejeck <[email protected]> Authored: Thu Oct 12 14:19:41 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Thu Oct 12 14:19:51 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/kafka/streams/KafkaStreams.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/43dda72f/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java index fd9c729..f5eb0a0 100644 --- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java +++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java @@ -113,10 +113,10 @@ import static org.apache.kafka.streams.StreamsConfig.PROCESSING_GUARANTEE_CONFIG * props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass()); * StreamsConfig config = new StreamsConfig(props); * - * KStreamBuilder builder = new KStreamBuilder(); - * builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic"); + * StreamsBuilder builder = new StreamsBuilder(); + * builder.<String, String>stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic"); * - * KafkaStreams streams = new KafkaStreams(builder, config); + * KafkaStreams streams = new KafkaStreams(builder.build(), config); * streams.start(); * }</pre> *
