Storm之事务和项目案例

三种事务:

  • 1、普通事务
  • 2、Partitioned Transaction - 分区事务
  • 3、Opaque Transaction - 不透明分区事务

Storm之事务和项目案例

Design details Manages state - 状态管理 Storm通过Zookeeper存储所有transaction相关信息(包含了:当前transaction id 以及batch的元数据信息) Coordinates the transactions - 协调事务 Storm会管理决定transaction应该处理什么阶段(processing、committing) Fault detection - 故障检测 Storm内部通过Acker机制保障消息被正常处理(用户不需要手动去维护) First class batch processing API Storm提供batch bolt接口