用 upsert-kafka connector 作为source，会有key的插入和更新出现乱序
想消费upsert-kafka的数据，以key为主键更新到数据库里面，会不会有消息乱序导致更新结果不对的情况？*来自志愿者整理的FLINK邮件归档
展开
收起
1
条回答
写回答
写回答
-
如果数据在upsert-kafka中已经做到了按序存储（相同key的数据放在同一个partition内），那么flink消费的时候可以做到保序。本质上，upsert-kafka是对kafka的封装，其内部仍然是一个消息队列，只是在消费的时候，我们形成一个视图。
消息从flink进入到kafka之中，根据kafka的协议保证了at-least-once。这里有对upsert-kafka完整的一个分析的讲解：深度解析 Flink upsert-kafka[1]。如果还有问题，可以继续咨询。
[1]https://flink-learning.org.cn/developers/flink-training-course3/*来自志愿者整理的FLINK邮件归档
2021-12-03 17:47:11赞同 展开评论 打赏
问答分类：
问答标签：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
