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 CDC 社区”。