如何理解Storm的并行度、Grouping策略以及消息可靠处理机制
如何理解Storm的并行度、Grouping策略以及消息可靠处理机制
1.Storm的并行度是指Storm中的一个Bolt可以接收到多少条消息。并行度的设置取决于拓扑的结构,一般来说,并行度越高,拓扑的执行效率越高。
2.Grouping策略是指在Storm中对消息进行分组的策略。Storm提供了多种不同的Grouping策略,例如随机分组、基于字段分组、基于流分组等。
3.消息可靠处理机制是指Storm中对消息进行可靠处理的机制。Storm提供了多种不同的消息可靠处理机制,例如数据库事务、消息队列事务、基于zookeeper的数据一致性等。
相关文章