如何在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