Apache Storm 中的并行性

Parallelism in Apache Storm

我是 Apache Storm 的新手,正在尝试为我的用例设计一个简单的拓扑。 Storm (Understanding the Parallelism of a Storm Topology) 中对并行性的解释给我留下了两个疑问:

1) 假设同一个工人将拥有执行者是否安全 如果我只有一个工人,我的喷嘴和螺栓?

2) worker 间通信使用 ZeroMQ,它使用网络进行通信而不是 LMX Disruptors 用于工人内部通信,它们在内存中时速度更快。我应该创建一个 worker 以获得更好的性能吗?

请回答以上问题,如有不妥请指正。

1) 是

2) 建议每台机器的每个拓扑使用一个 worker,因为进程内通信在 Storm 中要昂贵得多。 参考:https://storm.apache.org/documentation/FAQ.html 同样根据我的经验,在一台机器上为相同的拓扑结构使用多个 worker 会对吞吐量产生负面影响。