请考虑拓扑的以下配置:
#spouts:2
#bolt:8
#workers:3
使用这种配置,其中一个工人将没有喷口,如果我们在喷口和螺栓之间应用localorshuffle分组,工人-3螺栓是否收到任何元组?
不,据我所知不是。当您使用localOrShuffle分组时,您的意思是如果可能的话,您希望发送到同一JVM内的任何bolt,并且只有在VM内没有适当的bolt任务时才发送到JVM外。
对于我的拓扑--我在一个任务上的负载为90%,而第二个任务的负载为0%。 为什么对多个工人来说这是不同的。
我是Apache Storm的新手,正在尝试为我的用例设计一个简单的拓扑。Storm中对并行性的解释(理解一个Storm拓扑的并行性)给我留下了两个疑问: 请回答以上疑问,如有不正确之处,请更正我的理解。
STORM 是一款免费且开源的WebSerivce测试工具 它的功能: 1,测试任意语言测试 WebService 2,可动态调用webservice的方法,即使输入参数需要使用复杂的数据类型 3,节省开发成本与时间。你完全不需要自己做一个测试WebService的客户端 4,一个UI测试多个WebService 5,编辑SOAP header 6,其他(自己找找新的功能 - -!)
我正在使用OpaqueTridentKafkaSpout来消费来自Kafka的消息。下面是代码。我忽略了配置,因为这会导致同一kafka消息在多个批处理中到达。 当Kafka喷口开始时,我得到以下错误一次,但之后运行平稳。