关于upsert-kafka connector的问题，如何解决？
用 upsert-kafka connector 作为source，会有key的插入和更新出现乱序导致结果不准的问题吗？*来自志愿者整理的flink
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
1
条回答
写回答
-
如果数据在upsert-kafka中已经做到了按序存储（相同key的数据放在同一个partition内），那么flink消费的时候可以做到保序。本质上，upsert-kafka是对kafka的封装，其内部仍然是一个消息队列，只是在消费的时候，我们形成一个视图。消息从flink进入到kafka之中，根据kafka的协议保证了at-least-once。如果还有问题，可以继续咨询！*来自志愿者整理的flink
2021-12-05 22:44:01赞同 展开评论
相关问答