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而不是
相关文章
相关标签/搜索