Hello folks I encounter an issue with flink CDC, have left a question last week, but didn't get any answers, can someone help me?
regarding the Postgresql WAL remove slot I wondering if would it be possible to create a temporary slot in the flink CDC job?
this is the discussions link https://github.com/ververica/flink-cdc-connectors/discussions/2065
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
Hello! I'll try to assist you with your question regarding Flink CDC.
Regarding your question, it is possible to create a temporary replication slot when using the Flink CDC connector for PostgreSQL. The replication.slot.name configuration property can be used to specify the name of the replication slot that Flink CDC will use. By default, the name of the slot is the same as the database name.
To create a temporary replication slot, you can set this configuration property to a unique name that has not been used before. This will create a new replication slot with the specified name and use it for the Flink CDC job. Once the job is done, you can remove the replication slot to release resources.
To remove a replication slot, you can use the PostgreSQL command SELECT pg_drop_replication_slot(slot_name);. This will remove the replication slot with the specified name, and the associated WAL files will be removed as well.
I hope this helps! Let me know if you have any further questions or concerns.
