spout仅将元组发送到bolt实例的子集
我刚从Storm开始。我有一个简单的一个喷口（1个执行器）和一个螺栓（4个执行器）的拓扑结构。喷口与螺栓通过“混排”连接。
从我所看到的情况来看，spout只将元组发送到bolt执行器的子集--这些执行器与spout运行在同一主机上。
这是意料之中的吗？有没有一种方法可以将负载分散到所有的bolt执行器上，无论它们运行在哪里？
共有1个答案
是的，这是意料之中的。我想你可以通过使用相同的喷口源来配置它，比如storm与kafka集成，然后创建2个拓扑，配置每个拓扑的每个喷口都有相同的主题和相同的zookeeper主机。
-
问题内容： 我有两个卡夫卡喷口，我要将其值发送到同一螺栓。 可能吗 ？ 问题答案： 是的，有可能： 您也可以使用任何其他分组。 更新： 为了区分使用者螺栓中的元组（即topic_1或topic_2），有两种可能性： 1）您可以使用操作员ID（如@ user-4870385所建议）： 2）您可以使用流名称（@zenbeni建议）。对于这种情况，两个喷口都需要声明命名流，而螺栓需要通过流名称连接到喷口
-
我是阿帕奇Storm的新手。 请救命！！ 我的拓扑： TopologyBuilder builder=new TopologyBuilder（）； 这里，我试图从事件流中获取长度为3的窗口中的第一个和最后一个事件。但是我得到的第一个和最后一个事件是一样的，因为KafkaSpout一次只发送一个元组。
-
(要求Workerman版本>=3.3.0) 基于Worker的多进程分组推送系统 require_once __DIR__ . '/../Workerman/Autoloader.php'; require_once __DIR__ . '/Channel/src/Server.php'; require_once __DIR__ . '/Channel/src/Clie
-
当我的拓扑使用Storm 1.1.0时，我遇到了一个问题，当拓扑具有高延迟的Bolt时，Storm会重新安排Bolt和spout或者让Bolt和spout崩溃。 现在我创建了一个LatencyTest-Topology来测试和处理这个问题。
-
我有storm topology（1个worker）设置，其中spout（java）从redis出列（使用blpop）事件并传输到bolts。但是有一个观察到的情况是，当队列超过200万，并且在storm Nimbus/Supervisor/Zookeeper/Worker日志中没有发现警告/异常时，一些事件没有被bolt接收（在clojure中，6-spout线程、50-bolt线程）。
-
本文向大家介绍怎么访问到子组件的实例或者子元素？相关面试题，主要包含被问及怎么访问到子组件的实例或者子元素？时的应答技巧和注意事项，需要的朋友参考一下 通过