kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: updated JavaDoc example for 0.9 tech-prev to 0.10
Date Thu, 02 Jun 2016 22:40:40 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk e6ca328f8 -> 245fa2bd8


HOTFIX: updated JavaDoc example for 0.9 tech-prev to 0.10

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Sriharsha Chintalapani, Ismael Juma, Guozhang Wang

Closes #1450 from mjsax/hotfix


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

Branch: refs/heads/trunk
Commit: 245fa2bd8c08bb17c0b2b7aad4aba145d3c49783
Parents: e6ca328
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Thu Jun 2 15:40:35 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Jun 2 15:40:35 2016 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/streams/KafkaStreams.java | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/245fa2bd/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 af6d973..f05b02c 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -62,14 +62,12 @@ import java.util.concurrent.atomic.AtomicInteger;
  *    Map&lt;String, Object&gt; props = new HashMap&lt;&gt;();
  *    props.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-stream-processing-application");
  *    props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
- *    props.put(StreamsConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
- *    props.put(StreamsConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
- *    props.put(StreamsConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
- *    props.put(StreamsConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+ *    props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
+ *    props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
  *    StreamsConfig config = new StreamsConfig(props);
  *
  *    KStreamBuilder builder = new KStreamBuilder();
- *    builder.from("my-input-topic").mapValue(value -&gt; value.length().toString()).to("my-output-topic");
+ *    builder.stream("my-input-topic").mapValues(value -&gt; value.length().toString()).to("my-output-topic");
  *
  *    KafkaStreams streams = new KafkaStreams(builder, config);
  *    streams.start();


Mime
View raw message