Update kafka_wordcount.py

marmbrus · Jan 27, 2015 · 31e2317 · 31e2317
1 parent 370ba61
commit 31e2317
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/src/main/python/streaming/kafka_wordcount.py b/examples/src/main/python/streaming/kafka_wordcount.py
@@ -39,7 +39,7 @@
 
 if __name__ == "__main__":
     if len(sys.argv) != 3:
-        print >> sys.stderr, "Usage: network_wordcount.py <zk> <topic>"
+        print >> sys.stderr, "Usage: kafka_wordcount.py <zk> <topic>"
         exit(-1)
 
     sc = SparkContext(appName="PythonStreamingKafkaWordCount")