开发者社区 问答 正文

Hello folks I encounter an issue with flink CDC, h

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

展开
收起
真的很搞笑 2023-04-19 12:40:13 173 分享 版权
1 条回答
写回答
取消 提交回答
  • 值得去的地方都没有捷径

    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.

    2023-04-19 14:38:31
    赞同 展开评论