SparkStreaming整合kafka实践

         kafka作为一个实时的分布式消息队列,实时的生产和消费消息,这里我们可以 1.KafkaUils.createDstream方式:利用SparkStreaming实时计算框架实时的读取kafka中的数据然后进行计算。在spark1.3版本后,kafkaUtils里面提供了两个创建dstream的方法,一种为KafkaUtils.createDstream,另一种为KafkaUt
相关文章
相关标签/搜索