flink cdc 采集PG数据库，PG数据库具体要开启哪些东西

为了让Flink CDC能够正确地采集PostgreSQL数据库中的数据变化，需要在PostgreSQL数据库中进行如下设置：

1. 开启wal_level

在PostgreSQL配置文件中，将wal_level设置为logical：

wal_level = logical

2. 开启max_replication_slots

在PostgreSQL配置文件中，将max_replication_slots设置为一个大于0的数值：

max_replication_slots = 5

3. 开启max_wal_senders

在PostgreSQL配置文件中，将max_wal_senders设置为一个大于0的数值：

max_wal_senders = 5

4. 创建逻辑复制槽

在PostgreSQL中创建一个逻辑复制槽，用于Flink CDC连接并读取数据。可以使用如下命令创建一个名为flink_cdc_slot的逻辑复制槽：

SELECT * FROM pg_create_logical_replication_slot('flink_cdc_slot', 'pgoutput');

5. 确保数据库用户具有访问逻辑复制槽的权限

在PostgreSQL中，需要确保连接Flink CDC的数据库用户具有访问逻辑复制槽的权限。可以使用如下命令为数据库用户授权：

GRANT ALL ON pg_replication_slots TO flink_cdc_user;

其中flink_cdc_user是连接Flink CDC的数据库用户的用户名。

以上就是在PostgreSQL中开启Flink CDC所需要的一些配置和设置。