From dc1eed0a6af190d5cf07dedcb0607a0a76e45d64 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 27 Jan 2015 11:47:20 -0800 Subject: [PATCH] Update kafka_wordcount.py --- examples/src/main/python/streaming/kafka_wordcount.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/examples/src/main/python/streaming/kafka_wordcount.py b/examples/src/main/python/streaming/kafka_wordcount.py index 7a023ee410735..58201f967664a 100644 --- a/examples/src/main/python/streaming/kafka_wordcount.py +++ b/examples/src/main/python/streaming/kafka_wordcount.py @@ -19,12 +19,9 @@ Counts words in UTF8 encoded, '\n' delimited text received from the network every second. Usage: network_wordcount.py - To run this on your local machine, you need to setup Kafka and create a producer first - $ bin/zookeeper-server-start.sh config/zookeeper.properties - $ bin/kafka-server-start.sh config/server.properties - $ bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 1 --topic test - $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test - + To run this on your local machine, you need to setup Kafka and create a producer first, see + http://kafka.apache.org/documentation.html#quickstart + and then run the example `$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\ spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \