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 <[email protected]> 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 <[email protected]> Authored: Thu Jun 2 15:40:35 2016 -0700 Committer: Guozhang Wang <[email protected]> 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();
