我是新来的。在spark流媒体中将来自kafka的消息作为xml格式使用。你能告诉我如何处理这个xml是spark流吗？
ygya80vv1#
spark streaming和kafka文档在上游提供了示例：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
1条答案
按热度按时间ygya80vv1#
spark streaming和kafka文档在上游提供了示例：
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