From d8fe204376e6911210525cd74a861e31b5f8617b Mon Sep 17 00:00:00 2001 From: huxi Date: Wed, 8 Jul 2020 01:46:02 +0800 Subject: [PATCH] KAFKA-10222: Incorrect methods show up in 0.10 Kafka Streams docs (#8980) Non-existent methods show up in the doc: builder.from("my-input-topic").mapValue(value -> value.length().toString()).to("my-output-topic"); There is no method named from or mapValues. They should be stream and mapValues respectively. Reviewers: Matthias J. Sax --- .../src/main/java/org/apache/kafka/streams/KafkaStreams.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 3a311a8f281..465517e8821 100644 --- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java +++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java @@ -71,7 +71,7 @@ import java.util.concurrent.atomic.AtomicInteger; * 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();