Storm之事务和项目案例
三种事务:
- 1、普通事务
- 2、Partitioned Transaction - 分区事务
- 3、Opaque Transaction - 不透明分区事务
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接口