SparkStreaming 之整合kafka0.10以上版本

直接貼代碼,註釋內都有詳細解釋: pom依賴:java <!--SparkStreaming 整合kafka0.10版本--> <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming-kafka-0-10_2.11</artifactId
相關文章
相關標籤/搜索