使用JMS进行Spark流式传输 - 无API

vsi*_*h28 5 apache-spark

是否有任何API /方法可以将Spark Streaming与JMS集成.我能够与Kafka和Sockets集成,但是我无法与Jms队列或主题集成.

小智 3

我认为你应该尝试在 Spark 中调用接收器 api。您需要创建自定义接收器

http://spark.apache.org/docs/latest/streaming-custom-receivers.html

另请检查来自 tathagat das 的依赖,他是 Spark 贡献者

www.apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-and-JMS-td5371.html

如果您需要详细帮助,请告诉我