Gibt es eine API/Möglichkeit, Spark-Streaming mit JMS zu integrieren. Ich bin in der Lage, mit Kafka und Sockets zu integrieren, aber mit Jms Warteschlange oder Thema zu integrieren, die ich nicht kann.Spark-Streaming mit JMS - Nein API
Ich denke, Sie sollten versuchen, Reciever API in Funke aufrufen. Sie müssen benutzerdefinierte Empfänger
http://spark.apache.org/docs/latest/streaming-custom-receivers.html
Überprüfen Sie auch verlassen von Tathagat das schaffen, die Funken Beitrag von
istwww.apache-spark-user-list.1001560.n3.nabble.com/Spark- Streaming-and-JMS-td5371.html
Wenn Sie Hilfe im Detail benötigen lassen Sie mich
weiß, ich weiß, das ist eine alte Post ist. Da arbeite ich an etwas ähnlichem. Sie können Funken jms Empfänger
, wie Sie mit diesen Kunden Empfänger benutzen Sie ankommt JMS-Nachricht zum Beispiel, wie onMessage() Methoden-, wenn eine JMS-Nachricht wird in diesem Code integriert werden? – vsingh28
Ich sende Ihnen morgen Beispielcode –
würden Sie in der Lage sein, den Beispielcode in github zu setzen? und einen Link zur Verfügung stellen? – user422930