You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/07/07 17:47:33 UTC

[kafka-site] branch asf-site updated: KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs (#272)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git


The following commit(s) were added to refs/heads/asf-site by this push:
     new 9c94752  KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs (#272)
9c94752 is described below

commit 9c94752bfe815362be9ced970d6e690c86474e0e
Author: huxi <hu...@hotmail.com>
AuthorDate: Wed Jul 8 01:47:25 2020 +0800

    KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs (#272)
    
    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 <ma...@confluent.io>
---
 0100/javadoc/org/apache/kafka/streams/KafkaStreams.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/0100/javadoc/org/apache/kafka/streams/KafkaStreams.html b/0100/javadoc/org/apache/kafka/streams/KafkaStreams.html
index 162b2a0..2da1928 100644
--- a/0100/javadoc/org/apache/kafka/streams/KafkaStreams.html
+++ b/0100/javadoc/org/apache/kafka/streams/KafkaStreams.html
@@ -130,7 +130,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
     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();