Flink CDC修改pg 这2个参数，但是第二个参数不生效，有大佬碰到过么？

在使用Flink CDC连接PostgreSQL时，您提到修改了max_wal_senders和max_replication_slots参数，但发现max_replication_slots参数未生效。以下是可能的原因分析及解决方案：

1. 参数未正确应用

PostgreSQL的配置参数需要在正确的配置文件中设置，并且需要重启数据库或重新加载配置才能生效。

• 检查配置文件：确保max_wal_senders和max_replication_slots参数已正确添加到PostgreSQL的主配置文件（通常是postgresql.conf）中。
• 重新加载配置：如果修改了配置文件，可以通过以下命令重新加载配置，而无需重启数据库：

  SELECT pg_reload_conf();
  

  或者直接重启PostgreSQL服务以确保参数生效。

2. 参数值冲突或限制

max_wal_senders和max_replication_slots之间存在依赖关系，max_replication_slots的值不能超过max_wal_senders的值。

• 验证参数值：确保max_wal_senders的值大于或等于max_replication_slots的值。例如：

  max_wal_senders = 999
  max_replication_slots = 996
  

  如果max_replication_slots的值大于max_wal_senders，则会导致参数不生效。

• 检查当前使用情况：通过以下SQL查询当前的复制槽和WAL发送器使用情况，确保有足够的资源分配给Flink作业：

  SELECT * FROM pg_stat_replication;
  SELECT * FROM pg_replication_slots;
  

3. 权限问题

修改max_replication_slots参数后，可能由于权限不足导致Flink CDC无法正确使用复制槽。

• 高权限账户：确保用于Flink CDC的数据库账户具有SUPERUSER权限，或者同时拥有LOGIN和REPLICATION权限。
• 验证权限：可以通过以下SQL检查账户权限：

  SELECT rolname, rolreplication FROM pg_roles WHERE rolname = '<yourUserName>';
  

4. 逻辑复制未启用

max_replication_slots参数仅在逻辑复制启用时生效。如果逻辑复制未正确配置，可能导致参数无效。

• 检查wal_level参数：确保wal_level参数已设置为logical，这是逻辑复制的必要条件。

  SHOW wal_level;
  

  如果wal_level不是logical，需要修改配置并重启数据库。

• 验证逻辑解码插件：确保PostgreSQL已安装并启用了逻辑解码插件（如pgoutput或wal2json）。可以通过以下SQL验证：

  SELECT * FROM pg_available_extensions WHERE name = 'pgoutput';
  

5. Flink CDC连接器配置问题

Flink CDC连接器本身可能未正确使用max_replication_slots参数。

• 检查Slot名称：确保Flink CDC连接器的slot.name参数未与其他复制槽冲突。如果Slot名称重复，可能导致连接器无法创建新的复制槽。
• 清理无效Slot：如果存在无效的复制槽，可能会占用资源。可以通过以下SQL清理无效Slot：

  SELECT pg_drop_replication_slot(slot_name) FROM pg_replication_slots WHERE active = false;
  

6. 版本兼容性问题

不同版本的PostgreSQL对max_replication_slots的支持可能存在差异。

• 版本限制：确保使用的PostgreSQL版本支持逻辑复制和max_replication_slots参数。例如，PostgreSQL 9.6及以上版本支持逻辑复制。
• 云服务限制：如果您使用的是阿里云RDS PostgreSQL或Amazon RDS for PostgreSQL，请参考对应文档确认是否需要额外配置（如rds.logical_replication参数）。

总结与建议

根据上述分析，您可以按照以下步骤排查问题： 1. 确保max_wal_senders和max_replication_slots参数已正确配置并重新加载。 2. 验证max_wal_senders的值是否大于或等于max_replication_slots。 3. 检查数据库账户权限，确保具有REPLICATION权限。 4. 确认wal_level参数已设置为logical，并启用了逻辑解码插件。 5. 清理无效的复制槽，避免资源占用。 6. 检查PostgreSQL版本和云服务限制，确保兼容性。

如果问题仍未解决，建议提供更详细的错误日志或现象描述，以便进一步分析。