root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <matthias@confluent.io>
This commit is contained in:
huxi 2020-07-08 01:46:02 +08:00 committed by GitHub
parent 0ab0369c92
commit d8fe204376
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
View File

@ -71,7 +71,7 @@ import java.util.concurrent.atomic.AtomicInteger;
* StreamsConfig config = new StreamsConfig(props); * StreamsConfig config = new StreamsConfig(props);
* *
* KStreamBuilder builder = new KStreamBuilder(); * 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); * KafkaStreams streams = new KafkaStreams(builder, config);
* streams.start(); * streams.start();