Flink CDC 中pgsql cdc关闭以后，replication_slot没有被释放掉咋办？

在使用Flink CDC连接PostgreSQL（PgSQL）时，如果CDC作业关闭后replication_slot未被释放且无法删除，可能是由于以下原因导致的。以下是详细的解决方案：

1. 检查Replication Slot的状态

首先需要确认replication_slot的状态是否为ACTIVE或INACTIVE。只有状态为INACTIVE的Slot才能被手动删除。

查询Slot状态

执行以下SQL语句，查看当前数据库中所有Replication Slot的状态：

SELECT slot_name, slot_type, active, database FROM pg_replication_slots;

• 如果active字段为true，表示该Slot正在被某个进程使用。
• 如果active字段为false，表示该Slot处于非活跃状态，可以尝试手动删除。

2. 手动释放Replication Slot

步骤 1：终止占用Slot的进程

如果Slot状态为ACTIVE，需要先终止占用该Slot的进程。可以通过以下命令找到并终止相关进程：

-- 查找占用Slot的进程ID
SELECT active_pid FROM pg_replication_slots WHERE slot_name = 'your_slot_name';

-- 终止进程
SELECT pg_terminate_backend(<active_pid>);

将<active_pid>替换为实际的进程ID。

步骤 2：删除Slot

在确保Slot不再被占用后，执行以下命令删除Slot：

SELECT pg_drop_replication_slot('your_slot_name');

将your_slot_name替换为实际的Slot名称。

3. 自动清理Slot配置

为了避免类似问题再次发生，可以在Flink作业的Postgres Source配置中添加以下参数，以确保CDC作业停止时自动清理Slot：

'debezium.slot.drop.on.stop' = 'true'

⚠️ 警告
启用此参数会导致WAL日志被回收，当作业重新启动时可能会丢失部分数据，无法保证At-Least-Once语义。请根据业务需求谨慎使用。

4. 使用阿里云RDS API删除Slot

如果通过SQL无法删除Slot，可以尝试使用阿里云RDS提供的API接口DeleteSlot来删除指定的Replication Slot。

请求参数

• DBInstanceId: 目标实例ID。
• SlotName: 要删除的Slot名称。
• SlotStatus: 确保Slot状态为INACTIVE。

示例

调用DeleteSlot接口删除名为slot_test01的Slot：

{
  "DBInstanceId": "your_instance_id",
  "SlotName": "slot_test01",
  "SlotStatus": "INACTIVE"
}

5. 检查权限问题

如果上述方法均无法删除Slot，请检查当前用户是否具有足够的权限。删除Slot需要以下权限之一： - SUPERUSER权限。 - 同时拥有LOGIN和REPLICATION权限。

如果权限不足，可以联系数据库管理员提升权限，或者使用高权限账号（如db_admin）执行操作。

6. 阿里云RDS控制台操作

如果使用API仍然无法解决问题，可以通过阿里云RDS控制台进行操作： 1. 登录RDS管理控制台。 2. 在左侧导航栏中选择“日志管理” > “WAL日志管理”。 3. 查看所有Replication Slot的信息。 4. 对于状态为INACTIVE的Slot，点击操作列的“删除”按钮。

7. 注意事项

• 及时管理Slot：未使用的Slot会持续占用WAL日志空间，可能导致磁盘空间耗尽，影响数据库正常运行。
• 避免重复创建Slot：建议为每个表显式设置slot.name参数，避免因默认Slot名称冲突导致的问题。

通过以上步骤，您可以有效解决Flink CDC关闭后replication_slot未释放的问题。如果问题仍未解决，请提供更多上下文信息以便进一步排查。