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:44 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 53c23bb5e -> 31fe1f98e


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


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/31fe1f98
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/31fe1f98
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/31fe1f98

Branch: refs/heads/trunk
Commit: 31fe1f98e2f19074360e85c8ec839356238f0b29
Parents: 53c23bb
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:41 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/31fe1f98/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