如何在spark spark和kafka中處理XMLmessage？

Question

我是新來的火花。在火花流中使用來自kafka的消息作爲xml格式。你能告訴我如何處理這個XML是火花流？

Answer 1

火花流和卡夫卡文檔可上游例子：
http://spark.apache.org/docs/latest/streaming-kafka-0-8-integration.html

下面是支持的版本的兼容性矩陣。自從您開始使用流式傳輸以來，首先堅持穩定版本：
http://spark.apache.org/docs/latest/streaming-kafka-integration.html

您可以使用此庫來處理來自Spark的XML記錄。
https://github.com/databricks/spark-xml