Spark Streaming使用Kafka数据源进行计算

1. 说明 Spark Streaming用于流式数据的处理。 在工程中需要引入 Maven 工件spark- streaming-kafka_2.11 来使用它。包内提供的 KafkaUtils 对象可以在StreamingContext 和 JavaStreamingContext 中以你的Kafka 消息创建出 DStream。 <dependency> <group
相关文章
相关标签/搜索