我编写了一个 Storm 拓扑，它用它的 spout 监听 kafka 上的特定主题。现在我必须在activeMQ上迁移它。是否可以使用 activeMQ 重现这些主题并创建像我使用 kafka 一样聆听它们的 spout？
我用谷歌搜索了它，但不清楚如何向主题发送消息或收听特定主题。在卡夫卡做类似的事情
data = new KeyedMessage<>("topic", sms);
producer.send(data);
发送有关主题的短信并创建一个
new kafkaspout("topic")
听它。在activeMQ中？
看来我必须做
Queue queue = session.createQueue("topic");
与主题数量一样多，然后要听它们，我必须写一些类似的东西
Queue queue = session.createQueue("topic");
consumer = session.createConsumer(queue);
我不确定这是正确的方法，我希望得到任何建议的支持！