apache-storm - 是否可以在一个拓扑中创建多个 spout？如何？

Question

我有两个主题 BACKUPDATA 和 LIVEDATA。
阅读这两个主题的最佳解决方案是什么？
1. 两种不同的拓扑？
2. 一种拓扑有两个 spout？
我尝试了两种不同的拓扑，但 Storm 没有将插槽分配给第二个拓扑。

Answer 1

是的，您可以在拓扑中使用多个 spout。

builder.setSpout("kafka-spout1", new KafkaSpout(spoutConf1), 1);
builder.setSpout("kafka-spout2", new KafkaSpout(spoutConf2), 1);

好吧，配置取决于您如何处理数据。

如果为两者创建单独的拓扑，那么一个拓扑故障问题不会影响另一个，但会影响运行成本。

并且在具有多个 spout 的单个拓扑的情况下，两者都会受到彼此故障的影响。如果您想同时从两个主题中收集数据，您应该使用多个 spout。