// consumer data from kafka

val tmp_stream = ReceiverLauncher.launch(ssc, props, numberOfReceivers,StorageLevel.MEMORY_ONLY)

tmp_stream.foreachRDD(rdd => {
  rdd.collect()
  val count = rdd.count()  // here I can get the count of datas
     // How can I get data here ?
})

你知道如何完成这个代码来获取数据吗 foreachRDD 从创建的流 ReceiverLauncher.launch