You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/06/02 22:40:40 UTC
kafka git commit: HOTFIX: updated JavaDoc example for 0.9 tech-prev
to 0.10
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 <ma...@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 <ma...@confluent.io>
Authored: Thu Jun 2 15:40:35 2016 -0700
Committer: Guozhang Wang <wa...@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<String, Object> props = new HashMap<>();
* 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 -> value.length().toString()).to("my-output-topic");
+ * builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
*
* KafkaStreams streams = new KafkaStreams(builder, config);
* streams.start();