PostgreSQL 11部分表逻辑复制失效问题及排查方法咨询

这种情况我在维护PG 11逻辑复制集群时也碰到过几次，结合实际经验给你梳理几个最可能的原因和对应的排查步骤：

1. 表的属性不满足逻辑复制要求 #

逻辑复制对表有一些硬性要求，最常见的问题是缺少主键/唯一约束且未配置REPLICA IDENTITY，或者表的权限、数据类型不符合要求：

• 先检查发布端表的复制标识配置：

  SELECT relname, relreplident FROM pg_class WHERE relname = '你的表名';
  

  如果结果是f（默认值），说明该表没有主键或唯一约束，此时更新/删除操作无法被逻辑复制捕获（插入操作可能正常，但也会有风险）。解决方法是给表添加主键，或者设置REPLICA IDENTITY为全表：

  ALTER TABLE 你的表名 REPLICA IDENTITY FULL;
  

• 检查发布端用户对该表的SELECT权限：

  SELECT has_table_privilege('发布端用户名', '你的表名', 'SELECT');
  

  如果返回f，需要给用户授权：

  GRANT SELECT ON 你的表名 TO 发布端用户名;
  

• 确认表没有使用逻辑复制不支持的数据类型（比如某些自定义类型、oid类型的特殊用法等），PG 11对大多数标准类型都支持，但自定义类型需要确保能被序列化。

2. 订阅与发布的关联状态异常 #

即使你移除并重新添加了表到发布，订阅端的关联状态可能没有正确更新：

• 检查订阅端的表同步状态：

  SELECT srrelid::regclass AS table_name, srsubstate AS sync_state
  FROM pg_subscription_rel 
  WHERE srsubid = (SELECT oid FROM pg_subscription WHERE subname = '你的订阅名');
  

  正常状态应该是r（ready），如果是i（初始化中）或d（未同步），说明表的同步流程卡住了。可以尝试重置该表的同步状态：

  ALTER SUBSCRIPTION 你的订阅名 DISABLE;
  ALTER SUBSCRIPTION 你的订阅名 REFRESH PUBLICATION;
  ALTER SUBSCRIPTION 你的订阅名 ENABLE;
  

• 检查发布端的复制槽状态：

  SELECT slot_name, active, restart_lsn FROM pg_replication_slots;
  

  找到对应订阅的复制槽，确保active为t，如果复制槽已失效，可以删除后重新创建订阅（注意备份数据）。

3. WAL日志被提前清理 #

如果发布端的WAL日志在订阅端消费前就被清理，新添加的表可能无法获取初始数据或后续变更：

• 检查发布端的WAL保留配置：

  SHOW wal_keep_segments; -- PG 11也支持wal_keep_size，可根据配置查看
  

  如果值过小，建议调大（比如设置为64或更高，根据业务量调整），避免WAL被过早清理。
• 对比发布端和订阅端的WAL进度：
  发布端执行：

  SELECT pg_current_wal_lsn();
  

  订阅端执行：

  SELECT replay_lsn FROM pg_stat_replication WHERE application_name = '你的订阅名';
  

  如果两者差距过大，说明订阅端严重滞后，可能需要重新初始化订阅。

4. 初始数据同步未完成或静默失败 #

有时候刷新订阅后，表的初始数据同步可能因为网络、锁或资源问题静默失败，但日志只记录WARNING级别信息：

• 对比发布端和订阅端的表行数，确认初始数据是否同步完成：

  -- 发布端
  SELECT COUNT(*) FROM 你的表名;
  -- 订阅端
  SELECT COUNT(*) FROM 你的表名;
  

• 检查订阅端的PostgreSQL日志（不要只看ERROR级别的内容），比如：

  grep -i "你的表名" /var/log/postgresql/postgresql-11-main.log
  

  可能会找到诸如“初始数据复制超时”“表锁等待”之类的警告信息。

5. 订阅端用户权限问题 #

虽然之前可能正常，但重新添加表后，订阅端用户可能缺少该表的权限：

• 在订阅端用订阅用户尝试访问发布端的表：

  psql -h 发布端IP -U 订阅用户名 -d 发布端数据库 -c "SELECT * FROM 你的表名 LIMIT 1;"
  

  如果报错，需要给订阅用户在发布端授权该表的SELECT权限。

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