java—localcluster中的不同拓扑在ApacheStorm中是否可以有同名的流和螺栓

zdwk9cvp 于 2021-06-24 发布在 Storm

关注(0)|答案(1)|浏览(342)

我需要在localcluster模式下运行多个storm项目。

ProjectA->TopologyA->Spout1(listing to some stream X )->Bolt1->Bolt2
ProjectB->TopologyB->Spout1(listing to some stream Y )->Bolt1->Bolt2
ProjectC->TopologyC->Spout1(listing to some stream Z )->Bolt1->Bolt2

当我运行项目a、b和c时，不知何故流被其他项目的喷口读取。原因可能是什么。
ps：对storm来说还比较陌生，我们试图从文档中找出答案，但没有找到具体的答案。

Java apache apache-storm apache-storm-topology

来源：https://stackoverflow.com/questions/50038722/can-different-topologies-in-localcluster-have-streams-and-bolts-with-same-name-i

1条答案

按热度按时间

ntjbwcob1#

可以。我想首先你应该弄清楚喷口的水流是否重叠。也就是说，您应该在spout1中放置一个日志，当您发出时记录该日志，然后尝试运行所有拓扑，并验证topologya和topologyb spout1示例是否正在读取相同的消息。
您是否正在启动一个或3个localclusters来运行这些拓扑？尝试启动一个提交所有拓扑的localcluster，我不确定localcluster是否设计为运行多个示例。

赞(0）回复(0）举报 2021-06-24

我来回答

java—localcluster中的不同拓扑在ApacheStorm中是否可以有同名的流和螺栓

1条答案

相关问题

热门标签

最新问答