【发布时间】:2018-03-31 05:56:44
【问题描述】:
我正在寻找是否有一种方法可以使用 spark 流而不使用 Flume 将流数据从 Kafka 直接加载到 HDFS。 我已经尝试过使用 Flume(Kafka 源和 HDFS 接收器)。
提前致谢!
【问题讨论】:
-
完美候选:Spark Streaming
标签: apache-spark apache-kafka hdfs flume
我正在寻找是否有一种方法可以使用 spark 流而不使用 Flume 将流数据从 Kafka 直接加载到 HDFS。 我已经尝试过使用 Flume(Kafka 源和 HDFS 接收器)。
提前致谢!
【问题讨论】:
标签: apache-spark apache-kafka hdfs flume
这是 Spark Streaming 的一个非常基本的功能。根据您使用的 spark 和 Kafka 版本,您可以查看您使用的版本的 spark 流式 kafka 集成文档。保存到 HDFS 就像 rdd.saveAsTextFile("hdfs:///directory/filename") 一样简单。
【讨论】:
Kafka Connect 有 HDFS connector。 Confluent 的文档have more information.
【讨论】: