File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
examples/src/main/python/streaming Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change 1919 Counts words in UTF8 encoded, '\n ' delimited text received from the network every second.
2020 Usage: network_wordcount.py <zk> <topic>
2121
22- To run this on your local machine, you need to setup Kafka and create a producer first
23- $ bin/zookeeper-server-start.sh config/zookeeper.properties
24- $ bin/kafka-server-start.sh config/server.properties
25- $ bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 1 --topic test
26- $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
27-
22+ To run this on your local machine, you need to setup Kafka and create a producer first, see
23+ http://kafka.apache.org/documentation.html#quickstart
24+
2825 and then run the example
2926 `$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\
3027 spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \
You can’t perform that action at this time.
0 commit comments