storm容错性和消息可靠性保证机制 kinglyjn 2018-12-19 storm的容错性机制Worker进程死亡当一个工作进程死亡,supervisor会尝试重启它,如果启动连续失败了一定的次数,无法发送心跳信息到 nimbus,则nimbus会在另一台主机上重新分配 Worker。
storm分组策略 kinglyjn 2018-12-17 内置分组策略storm 内置了 8 种流分组的方式,通过实现 CustomStreamGrouping 接口可以实现自定义的流分组。InputDeclarer 接口定义了不同的流分组方式,每当TopologyBuilder#setBolt 方法被调用就返回该对象,用于声明一个bolt的输入流以及这些流应当如何分组。该接口定义的所有分组方法如下: