flink cdc 采集PG数据库,PG数据库具体要开启哪些东西
时间: 2023-07-25 15:07:05 浏览: 88
要使用 Flink CDC 采集PostgreSQL数据库,需要确保以下条件:
1. PostgreSQL版本:PostgreSQL 10或以上版本。
2. wal_level设置:确保 PostgreSQL 的`wal_level`设置为`logical`,在`postgresql.conf`配置文件中进行设置。
3. max_replication_slots设置:确保 PostgreSQL 的`max_replication_slots`设置足够大,比如设置为`100`,在`postgresql.conf`配置文件中进行设置。
4. max_wal_senders设置:确保 PostgreSQL 的`max_wal_senders`设置足够大,比如设置为`10`,在`postgresql.conf`配置文件中进行设置。
5. pgoutput插件启用:确保 PostgreSQL 的`pgoutput`插件已经启用,可以通过在`postgresql.conf`配置文件中设置`shared_preload_libraries = 'pgoutput'`来启用该插件。
6. 创建逻辑复制槽:使用以下命令创建逻辑复制槽:
```
SELECT pg_create_logical_replication_slot('flink_cdc', 'pgoutput');
```
这个命令会在 PostgreSQL 中创建一个名为`flink_cdc`的逻辑复制槽。
确保以上条件都已满足后,就可以使用 Flink CDC 来采集 PostgreSQL 数据库了。
阅读全文