必读:再讲Spark与kafka 0.8.2.1+整合

Kafka在0.8和0.10版本引入了新的消费者API,因此spark Streaming与kafka的整合提供了两个包。  请根据你的集群选用正确的包。注意, 0.8和后期的版本0.9及0.10是兼容的,可是0.10整合是不兼容以前的版本的。apache 包与版本特性之间的对应关系以下:api 本文主要讲述spark Streaming与kafka 0.8.2.1+版本整合,要求kafka集群的
相关文章
相关标签/搜索