kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka-site] branch asf-site updated: KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs (#272)
Date Tue, 07 Jul 2020 17:47:33 GMT
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 <huxi_2b@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 <matthias@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();


Mime
View raw message