我有两个主题BACKUPDATA和LIVEDATA。
阅读这两个主题的最佳解决方案是什么?
1.两种不同的拓扑?
2.一种带有两个喷嘴的拓扑?
我尝试使用两种不同的拓扑,但没有为第二种拓扑分配插槽。

最佳答案

是的,您可以在拓扑中使用多个喷嘴。

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

好了,配置取决于您如何处理数据。

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

并且在具有多个喷口的单个拓扑的情况下,两者都会受到彼此故障的影响。如果要同时合并来自两个主题的数据,则应使用多个喷嘴。

关于apache-storm - 是否可以在一个拓扑中创建多个喷嘴?如何?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/23978034/

10-12 06:01