如何理解Storm的并行度、Grouping策略以及消息可靠处理机制

2023-04-08 13:13:00 并行 理解 可靠

如何理解Storm的并行度、Grouping策略以及消息可靠处理机制

1.Storm的并行度是指Storm中的一个Bolt可以接收到多少条消息。并行度的设置取决于拓扑的结构,一般来说,并行度越高,拓扑的执行效率越高。

2.Grouping策略是指在Storm中对消息进行分组的策略。Storm提供了多种不同的Grouping策略,例如随机分组、基于字段分组、基于流分组等。

3.消息可靠处理机制是指Storm中对消息进行可靠处理的机制。Storm提供了多种不同的消息可靠处理机制,例如数据库事务、消息队列事务、基于zookeeper的数据一致性等。

相关文章