我想从solace队列接收消息，并想通过apachestorm存储在hbase/hdfs之类的任何数据存储中。
solace已经发布了集成指南来设置一个自定义接收器，它将消息存储在spark内存中。除与apachestorm集成外，还提供了其他集成指南。
我不确定这是否可能。如果是这样的话，如果有人已经这样做了，他们是否可以给出一些相同的建议（如果不是安慰其他消息提供者的话）？
我想从solace队列接收消息，并想通过apachestorm存储在hbase/hdfs之类的任何数据存储中。
solace已经发布了集成指南来设置一个自定义接收器，它将消息存储在spark内存中。除与apachestorm集成外，还提供了其他集成指南。
我不确定这是否可能。如果是这样的话，如果有人已经这样做了，他们是否可以给出一些相同的建议（如果不是安慰其他消息提供者的话）？
1条答案
按热度按时间9udxz4iz1#
看看apachestorm的文档，有两种方法可以做到这一点。
通过mqtt集成-https://storm.apache.org/releases/1.0.0/storm-mqtt.html
通过jms集成-https://github.com/ptgoetz/storm-jms
storm jms项目提供了
SpringJmsProvider您可以使用spring框架（solace有一个集成指南）来查找ConnectionFactory以及Destination.或者，您可以实现自己的
org.apache.storm.jms.JmsProvider提供ConnectionFactory以及Destination没有Spring框架。