java Storm群集配置
我目前有一个Storm群集运行在3台Unix机器上(1台用于Nimbus/Zookeeper,另外两台作为主管)
我的拓扑配置如下:
JMSDataSpout1&;JMSDataSpout2->;EsperBolt->;JMSBolt
在我的集群环境中,我看到Nimbus将喷嘴部署到两台不同的机器上。这很好,但我不禁想知道——我的另外两个螺栓也会这样吗
具体来说,如果我通过JMSDataSpout1接收到消息,但同一台机器上不存在EsperBolt实例,会发生什么情况
Nimbus是否会识别该信息并将其转发到另一台机器上运行的EsperBolt上,或者该信息是否丢失
# 1 楼答案
它将通过网络将其发送给螺栓运行的主管。Nimbus甚至不会参与这个过程,只会告诉主管它应该将元组发送到哪里