【十五】Spark Streaming整合Kafka使用Direct方式（使用Scala語言）

官網介紹html Kafka提供了新的consumer api 在0.8版本和0.10版本之間。0.8的集成是兼容0.9和0.10的。可是0.10的集成不兼容之前的版本。java 這裏使用的集成是spark-streaming-kafka-0-8。官方文檔node 配置SparkStreaming接收從kafka來的數據有兩種方式。老的方式要使用Receiver，新的方式是Spark1.3後引進的

>>阅读原文<<