I am using : kafka 0.8.1 spark-streaming-kafka_2.10-0.9.0-cdh5.0.2 My analysis is simple, so I confuse why it cost so long time at "take at DStream.scala:586", it cost 2 to 8 minutes or longer .I don't know how to find the reason. Hoping your help.
Sorry for my poor english. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-streaming-kafka-cost-long-time-at-take-at-DStream-scala-586-tp8837.html Sent from the Apache Spark User List mailing list archive at Nabble.com.