Flink CDC中pg的复制槽需要自己手工创建吗?有没得创建的说明?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink PostgreSQL CDC不需要手动创建或预分配wal复制槽。它会自动根据需要来管理wal复制槽。
具体来说:
默认Flink CDC会使用wal_keep_size参数指定的wal文件大小来动态申请和回收wal复制槽。
也可以通过配置项"pgoutput.slot.name"手动指定一个复制槽名称,CDC会使用该槽。
但无论手动指定还是自动管理,槽的创建和回收均由CDC完成,不需要用户参与。
所以在使用Flink PostgreSQL CDC时:
不需要预分配或创建wal复制槽
可以忽略槽的概念,CDC会自动管理
可以通过配置项指定一个槽名以兼容其他系统
槽的生命周期交给CDC,用户无需手动操作槽
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。