SparkStreaming 之整合kafka0.10以上版本

直接贴代码,注释内都有详细解释: pom依赖:java <!--SparkStreaming 整合kafka0.10版本--> <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming-kafka-0-10_2.11</artifactId
相关文章
相关标签/搜索