Spark 31 简单示例：Kafka + sparkStreaming

 package com.sparkStreaming

    
  
    
 import org.apache.kafka.common.serialization.StringDeserializer
    
 import org.apache.spark.SparkConf
    
 import org.apache.spark.streaming.{Seconds, StreamingContext}
    
 import org.apache.spark.streaming.kafka010._
    
 import org.apache.spark.streaming.kafka010.ConsumerStrategies.Subscribe
    
  
    
 object KafkaDirectorDemo {
    
   def main(args: Array[String]): Unit = {
    
     var sparkConf = new SparkConf().setAppName("ccc").setMaster("local[*]")
    
     var ssc = new StreamingContext(sparkConf, Seconds(5))