【十五】Spark Streaming整合Kafka使用Direct方式(使用Scala语言)

官网介绍html Kafka提供了新的consumer api 在0.8版本和0.10版本之间。0.8的集成是兼容0.9和0.10的。可是0.10的集成不兼容之前的版本。java 这里使用的集成是spark-streaming-kafka-0-8。官方文档node 配置SparkStreaming接收从kafka来的数据有两种方式。老的方式要使用Receiver,新的方式是Spark1.3后引进的
相关文章
相关标签/搜索