kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Update JavaDoc to use new API
Date Thu, 12 Oct 2017 21:19:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/1.0 fbbfc2bc0 -> 43dda72f6


MINOR: Update JavaDoc to use new API

Author: Bill Bejeck <bill@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Matthias J. Sax<matthias@confluent.io>

Closes #4068 from bbejeck/MINOR_fix_java_doc_example_for_1_0_API

(cherry picked from commit 31fe1f98e2f19074360e85c8ec839356238f0b29)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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 <bill@confluent.io>
Authored: Thu Oct 12 14:19:41 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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>
  *


Mime
View raw message