我刚从风暴开始。我有一个喷口（1个执行器）和一个螺栓（4个执行器）的简单拓扑结构。喷口和螺栓通过“组合”连接。从我所看到的情况来看，spout只将元组发送到bolt执行器的一个子集—那些与spout运行在同一主机上的执行器。这是预期的吗？有没有办法将荷载分散到所有螺栓执行器上，无论它们在哪里运行？
mgdq6dx11#
是的，这是意料之中的。我认为您可以使用相同的喷口源来配置它，比如storm integrate with kafka，然后创建2个拓扑，使用相同的主题和相同的zookeeper主机配置每个拓扑的每个喷口。
1条答案
按热度按时间mgdq6dx11#
是的，这是意料之中的。我认为您可以使用相同的喷口源来配置它，比如storm integrate with kafka，然后创建2个拓扑，使用相同的主题和相同的zookeeper主机配置每个拓扑的每个喷口。