SparkStreaming + Kafka集成指南(Kafka版本要求0.10.0以上)

原文連接:http://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html SparkStreaming集成Kafka0.10版本與集成0.8版本Kafka的 直接鏈接方式相似。提供了簡單的並行性以及Kafka分區和Spark分區之間一對一的映射,以及元數據和偏移量的訪問。然而,由於使用 新版本的消費者的API而不是
相關文章
相關標籤/搜索