Spark 0.10
-
如何实现Kafka与Spark 0.10版本的集成连接?
Kafka和Spark 0.10的连接可以通过Spark Streaming API实现。在Spark应用程序中,可以使用KafkaUtils.createStream()方法创建一个接收Kafka数据的DStream对象。可以对该DStream对象进行各种操作,如过滤、映射、聚合等。
Kafka和Spark 0.10的连接可以通过Spark Streaming API实现。在Spark应用程序中,可以使用KafkaUtils.createStream()方法创建一个接收Kafka数据的DStream对象。可以对该DStream对象进行各种操作,如过滤、映射、聚合等。