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 2019/05/10 09:56:29 UTC
[kafka] branch 2.2 updated: KAFKA-8348: Fix KafkaStreams JavaDocs
(#6707)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push:
new c9ebcd6 KAFKA-8348: Fix KafkaStreams JavaDocs (#6707)
c9ebcd6 is described below
commit c9ebcd6652a0b00209ebdc3ece2e2f07212f4f8c
Author: Lifei Chen <li...@allseeingsecurity.com>
AuthorDate: Fri May 10 17:54:09 2019 +0800
KAFKA-8348: Fix KafkaStreams JavaDocs (#6707)
---
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 3c8ee16..60053aa 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -106,14 +106,14 @@ import static org.apache.kafka.streams.internals.ApiUtils.prepareMillisCheckFail
* <p>
* A simple example might look like this:
* <pre>{@code
- * Map<String, Object> props = new HashMap<>();
+ * Properties props = new Properties();
* props.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-stream-processing-application");
* props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
* props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
* props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
*
* StreamsBuilder builder = new StreamsBuilder();
- * builder.<String, String>stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
+ * builder.<String, String>stream("my-input-topic").mapValues(value -> String.valueOf(value.length())).to("my-output-topic");
*
* KafkaStreams streams = new KafkaStreams(builder.build(), props);
* streams.start();