在Streaming Processing场景中,为什么需要保证数据的可重复读?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
在Streaming Processing场景中,保证数据的可重复读是为了在发生故障时能够从上一次成功处理的状态正确恢复。这要求消息消费者能够准确地定位并回放读取特定位点的消息,而消息存储系统必须保证下游消费者观察到的数据进度不会超出集群已确认提交的最新状态。