spark怎么處理kafka中的json的數(shù)據(jù)？構(gòu)造函數(shù)是KafkaUtils.createDstream創(chuàng)建（SSC，[ZK]，[consumer group ID]，[per topic，part

spark怎么處理kafka中的json的數(shù)據(jù)？

構(gòu)造函數(shù)是KafkaUtils.createDstream創(chuàng)建（SSC，[ZK]，[consumer group ID]，[per topic，partitions]）使用Kafka高級(jí)使用者API使用接收器接收數(shù)據(jù)。對(duì)于所有接收器，接收到的數(shù)據(jù)將保存在spark executors中，然后通過(guò)spark Streaming啟動(dòng)作業(yè)來(lái)處理數(shù)據(jù)，默認(rèn)情況下這些數(shù)據(jù)將丟失。它可以啟用存儲(chǔ)在HDFS上的wal日志