integration - 如何将 Apache Storm 与 Solace 消息队列集成以接收来自 Solace 的消息 .. 就像火花流集成一样

Question

我想从Solace队列接收消息，并希望通过 Apache Storm 存储在 Hbase/HDFS 等任何数据存储中。

Solace 发布了集成指南来设置自定义接收器，它将消息存储在 Spark 内存中。除了与 Apache Storm 的集成外，还提供了其他集成指南。

我不确定这是否可能。如果是这样，如果他们已经这样做了，任何人都可以给出一些相同的指示（如果不能安慰其他消息传递提供者）吗？

Answer 1

查看 Apache Storm 的文档，有两种方法可以解决这个问题。

1. 通过 MQTT 集成 - https://storm.apache.org/releases/1.0.0/storm-mqtt.html

2. 通过 JMS 集成 - https://github.com/ptgoetz/storm-jms

   storm-jms 项目提供了一个SpringJmsProvider可以使用 Spring 框架（Solace 有一个集成指南）来查找ConnectionFactory和Destination.

   或者，您可以实现自己的org.apache.storm.jms.JmsProvider以提供ConnectionFactory和Destination不提供 Spring 框架。