Flink CDC连kafka的时候,如果消费掉的消息,能删除掉吗?
是的,Flink CDC在连接到Kafka时,可以消费掉的消息并将其删除。这是因为Flink CDC会监控并捕获数据库的变动,包括数据的插入、更新和删除,然后将这些变更按发生的顺序完整记录下来,写入到消息中间件中以供其他服务进行订阅及消费。当Flink CDC消费掉Kafka中的消息后,它会自动删除这些消息,以防止重复消费。
楼主你好,据我所知道的,阿里云Flink CDC在消费Kafka消息时,可以设置多种不同的消费模式(如自动提交、手动提交等),但无论采用何种方式,都无法删除Kafka上已经消费掉的消息。因为Kafka本身是一个持久化存储系统,它会一直保存所有的消息,除非你手动删除或自动过期删除。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。