0

Ich möchte Nachrichten von Solace Warteschlangen empfangen und in beliebigen Datenspeichern wie Hbase/HDFS über Apache Storm speichern.So integrieren Sie Apache Storm mit Solace Nachrichtenwarteschlange zum Empfangen von Nachrichten von Solace .. genau wie Spark-Streaming-Integration

Solace hat integration guide veröffentlicht, um einen benutzerdefinierten Empfänger einzurichten, der die Nachrichten in Spark im Speicher speichert. Andere integration guides waren ebenfalls verfügbar, außer der Integration mit Apache Storm.

Ich bin mir nicht sicher, ob das möglich ist oder nicht. Wenn das ist, Kann jemand einige Hinweise auf die gleiche (wenn nicht ein anderer Messaging-Anbieter Trost) geben, wenn sie das bereits getan haben?

+0

Warum über Storm? Flume kann tun, was Sie auf Hbase/HDFS schreiben möchten –

+0

Frühere Lösung, die wir mit Flume hatten. mit Hbase - AsyncHbaseSink, die gut funktionierte. Ich weiß, dass es mit Flume erreicht werden kann. Wir haben auch mit Spark Streaming mit Trost versucht, es funktioniert gut. Diese Frage ist spezifisch für Storm, um zu testen, ob es funktioniert oder nicht. Dies versuchen wir für bessere Werkzeuge und Techniken –

Antwort

2

Wenn wir uns die Dokumentation von Apache Storm anschauen, gibt es zwei Möglichkeiten.

  1. über MQTT Integrieren - https://storm.apache.org/releases/1.0.0/storm-mqtt.html
  2. über JMS integrieren - https://github.com/ptgoetz/storm-jms

    Die Sturm-jms-Projekt bietet ein SpringJmsProvider, wo Sie die Verwendung des Spring-Framework machen können (was Solace hat ein Integrationshandbuch für) nach einem ConnectionFactory und Destination suchen.

    Alternativ können Sie Ihre eigenen org.apache.storm.jms.JmsProvider implementieren, um eine ConnectionFactory und Destination ohne das Spring Framework bereitzustellen.