0
私はスパークするのが新しいです。スパークストリーミングのXMLフォーマットとしてkafkaからのメッセージを消費します。このxmlを処理する方法をスパークストリーミングで教えてください。sparkストリーミングとkafkaでXMLmessageを処理する方法は?
私はスパークするのが新しいです。スパークストリーミングのXMLフォーマットとしてkafkaからのメッセージを消費します。このxmlを処理する方法をスパークストリーミングで教えてください。sparkストリーミングとkafkaでXMLmessageを処理する方法は?
スパークストリーミングおよびカフカドキュメントは、実施例上流入手可能である:
http://spark.apache.org/docs/latest/streaming-kafka-0-8-integration.html
ここでサポートされているバージョンの互換性マトリックスです。
http://spark.apache.org/docs/latest/streaming-kafka-integration.html
あなたがスパークからXMLレコードを処理するために、このライブラリを使用することができます。あなたはストリーミングを使い始めるしているので、最初の安定版リリースに固執します。
https://github.com/databricks/spark-xml