kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Improve topic management instructions for Kafka Streams examples
Date Thu, 06 Apr 2017 11:35:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 2dfeff064 -> 8e35721ce


MINOR: Improve topic management instructions for Kafka Streams examples

Author: Michael G. Noll <michael@confluent.io>

Reviewers: Matthias J. Sax <matthias@confluent.io>, Eno Thereska <eno@confluent.io>,
Ismael Juma <ismael@juma.me.uk>

Closes #2812 from miguno/trunk-streams-examples-docs

(cherry picked from commit 6ba98f6e5ad8776b7268441b5392330496565814)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8e35721c
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8e35721c
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8e35721c

Branch: refs/heads/0.10.2
Commit: 8e35721ce811cb0807b45d3a18c55329f2f79c4c
Parents: 2dfeff0
Author: Michael G. Noll <michael@confluent.io>
Authored: Thu Apr 6 12:34:19 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu Apr 6 12:34:38 2017 +0100

----------------------------------------------------------------------
 .../kafka/streams/examples/pageview/PageViewTypedDemo.java    | 7 ++++---
 .../kafka/streams/examples/pageview/PageViewUntypedDemo.java  | 5 +++--
 .../java/org/apache/kafka/streams/examples/pipe/PipeDemo.java | 5 +++--
 .../kafka/streams/examples/wordcount/WordCountDemo.java       | 5 +++--
 .../streams/examples/wordcount/WordCountProcessorDemo.java    | 5 +++--
 5 files changed, 16 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8e35721c/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
index 4756722..7a93075 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
@@ -42,12 +42,13 @@ import java.util.Properties;
  * using specific data types (here: JSON POJO; but can also be Avro specific bindings, etc.)
for serdes
  * in Kafka Streams.
  *
- * In this example, we join a stream of pageviews (aka clickstreams) that reads from  a topic
named "streams-pageview-input"
+ * In this example, we join a stream of pageviews (aka clickstreams) that reads from a topic
named "streams-pageview-input"
  * with a user profile table that reads from a topic named "streams-userprofile-input", where
the data format
  * is JSON string representing a record in the stream or table, to compute the number of
pageviews per user region.
  *
- * Before running this example you must create the source topic (e.g. via bin/kafka-topics.sh
--create ...)
- * and write some data to it (e.g. via bin-kafka-console-producer.sh). Otherwise you won't
see any data arriving in the output topic.
+ * Before running this example you must create the input topics and the output topic (e.g.
via
+ * bin/kafka-topics.sh --create ...), and write some data to the input topics (e.g. via
+ * bin/kafka-console-producer.sh). Otherwise you won't see any data arriving in the output
topic.
  */
 public class PageViewTypedDemo {
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/8e35721c/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java
index 67e8cc5..68becde 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java
@@ -50,8 +50,9 @@ import java.util.Properties;
  * with a user profile table that reads from a topic named "streams-userprofile-input", where
the data format
  * is JSON string representing a record in the stream or table, to compute the number of
pageviews per user region.
  *
- * Before running this example you must create the source topic (e.g. via bin/kafka-topics.sh
--create ...)
- * and write some data to it (e.g. via bin-kafka-console-producer.sh). Otherwise you won't
see any data arriving in the output topic.
+ * Before running this example you must create the input topics and the output topic (e.g.
via
+ * bin/kafka-topics.sh --create ...), and write some data to the input topics (e.g. via
+ * bin/kafka-console-producer.sh). Otherwise you won't see any data arriving in the output
topic.
  */
 public class PageViewUntypedDemo {
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/8e35721c/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java
index 3c1bd8c..6626f45 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java
@@ -32,8 +32,9 @@ import java.util.Properties;
  * In this example, we implement a simple "pipe" program that reads from a source topic "streams-file-input"
  * and writes the data as-is (i.e. unmodified) into a sink topic "streams-pipe-output".
  *
- * Before running this example you must create the source topic (e.g. via bin/kafka-topics.sh
--create ...)
- * and write some data to it (e.g. via bin-kafka-console-producer.sh). Otherwise you won't
see any data arriving in the output topic.
+ * Before running this example you must create the input topic and the output topic (e.g.
via
+ * bin/kafka-topics.sh --create ...), and write some data to the input topic (e.g. via
+ * bin/kafka-console-producer.sh). Otherwise you won't see any data arriving in the output
topic.
  */
 public class PipeDemo {
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/8e35721c/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java
index b1d3c52..892c66c 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java
@@ -40,8 +40,9 @@ import java.util.Properties;
  * represent lines of text; and the histogram output is written to topic "streams-wordcount-output"
where each record
  * is an updated count of a single word.
  *
- * Before running this example you must create the source topic (e.g. via bin/kafka-topics.sh
--create ...)
- * and write some data to it (e.g. via bin-kafka-console-producer.sh). Otherwise you won't
see any data arriving in the output topic.
+ * Before running this example you must create the input topic and the output topic (e.g.
via
+ * bin/kafka-topics.sh --create ...), and write some data to the input topic (e.g. via
+ * bin/kafka-console-producer.sh). Otherwise you won't see any data arriving in the output
topic.
  */
 public class WordCountDemo {
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/8e35721c/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java
index 9d2424a..aefaf41 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java
@@ -41,8 +41,9 @@ import java.util.Properties;
  * represent lines of text; and the histogram output is written to topic "streams-wordcount-processor-output"
where each record
  * is an updated count of a single word.
  *
- * Before running this example you must create the source topic (e.g. via bin/kafka-topics.sh
--create ...)
- * and write some data to it (e.g. via bin/kafka-console-producer.sh). Otherwise you won't
see any data arriving in the output topic.
+ * Before running this example you must create the input topic and the output topic (e.g.
via
+ * bin/kafka-topics.sh --create ...), and write some data to the input topic (e.g. via
+ * bin/kafka-console-producer.sh). Otherwise you won't see any data arriving in the output
topic.
  */
 public class WordCountProcessorDemo {
 


Mime
View raw message