spark廣播變量原理 spark怎么處理kafka中的json的數據？
spark怎么處理kafka中的json的數據？構造函數是KafkaUtils.createDstream創(chuàng)建（SSC，[ZK]，[consumer group ID]，[per topic，part
spark怎么處理kafka中的json的數據？
構造函數是KafkaUtils.createDstream創(chuàng)建（SSC，[ZK]，[consumer group ID]，[per topic，partitions]）使用Kafka高級使用者API使用接收器接收數據。對于所有接收器，接收到的數據將保存在spark executors中，然后通過spark Streaming啟動作業(yè)來處理數據，默認情況下這些數據將丟失。它可以啟用存儲在HDFS上的wal日志