必讀:再講Spark與kafka 0.8.2.1+整合

Kafka在0.8和0.10版本引入了新的消費者API,所以spark Streaming與kafka的整合提供了兩個包。  請根據你的集羣選用正確的包。注意, 0.8和後期的版本0.9及0.10是兼容的,但是0.10整合是不兼容之前的版本的。 包與版本特性之間的對應關係如下: 本文主要講述spark Streaming與kafka 0.8.2.1+版本整合,要求kafka集羣的版本是0.8.2.
相關文章
相關標籤/搜索