fixed #84 修复存储消费进度时，潜在的并发问题
Merge https://github.com/alibaba/RocketMQ