update logging and comment

Author: Davies Liu

examples/src/main/python/streaming/kafka_wordcount.py

@@ -22,12 +22,13 @@
  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
 
  and then run the example
-    `$ bin/spark-submit --driver-class-path lib_managed/jars/kafka_*.jar:\
-      external/kafka/target/scala-*/spark-streaming-kafka_*.jar examples/src/main/python/\
-      streaming/kafka_wordcount.py localhost:2181 test`
+    `$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\
+      spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \
+      localhost:2181 test`
 """
 
 import sys

python/pyspark/streaming/kafka.py

@@ -73,10 +73,9 @@ def getClassByName(name):
         except Py4JError, e:
             # TODO: use --jar once it also work on driver
             if not e.message or 'call a package' in e.message:
-                print "No kafka package, please build it and add it into classpath:"
-                print " $ sbt/sbt streaming-kafka/package"
-                print " $ bin/submit --driver-class-path lib_managed/jars/kafka_2.10-0.8.0.jar:" \
-                    "external/kafka/target/scala-2.10/spark-streaming-kafka_2.10-1.3.0-SNAPSHOT.jar"
+                print "No kafka package, please put the assembly jar into classpath:"
+                print " $ bin/submit --driver-class-path external/kafka-assembly/target/" + \
+                      "scala-*/spark-streaming-kafka-assembly-*.jar"
             raise e
         ser = PairDeserializer(NoOpSerializer(), NoOpSerializer())
         stream = DStream(jstream, ssc, ser)