PostgreSQL逻辑复制报错：replication slot不存在求助

问题场景 #

在Kubernetes环境部署的两个PostgreSQL实例间配置逻辑复制，执行以下操作后订阅库日志报错：

1. 源库创建逻辑复制槽与发布：

   SELECT pg_create_logical_replication_slot('sub_test', 'pgoutput');
   CREATE PUBLICATION pub FOR TABLE "AOI";
   

2. 订阅库创建订阅：

   CREATE SUBSCRIPTION sub_test CONNECTION 'postgresql://user:password@localhost:5432/postgres' 
   PUBLICATION pub 
   WITH (slot_name=sub_test, create_slot=false, copy_data=True);
   

订阅库报错信息：

2024-05-30 15:49:46.654 UTC [2883] ERROR: replication slot "sub_test" does not exist
2024-05-30 15:49:46.654 UTC [2883] STATEMENT: START_REPLICATION SLOT "sub_test" LOGICAL 0/0 (proto_version '1', publication_names '"pub"')
2024-05-30 15:49:46.654 UTC [2881] ERROR: could not start WAL streaming: ERROR: replication slot "sub_test" does not exist

核心排查方向与解决方法 #

1. 订阅连接了错误的数据库实例 #

订阅连接字符串用了localhost:5432，但在Kubernetes Pod环境中，localhost指向订阅库自身Pod，而非源库Pod。这会导致订阅尝试连接自身数据库，但自身未创建sub_test复制槽，因此报错。

• 解决：把连接字符串中的localhost替换为Kubernetes集群内源库的服务名称（例如postgres-source.default.svc.cluster.local）或源库Pod的IP，确保连接到正确的源数据库。

2. 复制槽创建在错误的数据库中 #

逻辑复制槽是数据库级对象，如果在源库的非postgres库中创建了sub_test槽，但订阅连接的是源库的postgres库，就会找不到该槽。

• 验证：在源库执行以下SQL，确认复制槽所在数据库是否与订阅连接的库一致：

  SELECT slot_name, database FROM pg_replication_slots WHERE slot_name = 'sub_test';
  

• 解决：要么在源库的postgres库中重新创建复制槽，要么修改订阅连接字符串中的数据库名称，使其与复制槽所在库匹配。

3. 复制槽已被意外删除 #

复制槽可能因误操作、源库max_replication_slots参数限制（槽数量超出上限导致旧槽被清理）或自定义清理脚本而被删除。

• 验证：在源库执行SELECT * FROM pg_replication_slots WHERE slot_name = 'sub_test';，若返回空结果则说明槽已不存在。
• 解决：重新在源库执行创建复制槽的语句；同时检查源库postgresql.conf中的max_replication_slots参数，确保值足够容纳所需的复制槽数量（默认值通常为10，可按需调整）。

4. 连接用户权限不足 #

订阅使用的数据库用户可能没有足够权限查看源库的复制槽，或连接用户并非源库中拥有复制权限的用户，权限不足可能伪装成“槽不存在”的报错。

• 解决：确保源库的连接用户拥有REPLICATION权限，或使用超级用户连接；执行以下SQL为用户赋予权限：

  ALTER USER your_user REPLICATION;
  

快速验证步骤 #

1. 确认源库的复制槽状态：
   在源库执行：

   SELECT slot_name, database, active FROM pg_replication_slots WHERE slot_name = 'sub_test';
   

   需确保有结果返回，且database字段与订阅连接的库一致，active字段显示为t（表示槽正在被使用）。

2. 测试订阅库到源库的连接与槽可见性：
   在订阅库Pod中执行以下命令，验证能否连接到源库并看到复制槽：

   psql postgresql://user:password@<源库服务名>:5432/postgres -c "SELECT slot_name FROM pg_replication_slots WHERE slot_name = 'sub_test';"
   

   如果返回槽名称，说明连接与槽状态正常；若连接失败或返回空，需排查网络或槽的配置问题。

内容的提问来源于stack exchange，提问作者jm22b