求助：Kafka PostgreSQL Source Connector运行后突发异常停止

我之前维护Debezium PostgreSQL Source Connector时也碰到过一模一样的问题，结合踩过的坑，给你梳理几个优先级最高的排查方向：

你看到的org.apache.kafka.connect.errors.ConnectException只是上层包装的错误，真正的问题藏在它下面的Caused By异常栈里。赶紧去Kafka Connect的日志文件（通常在$CONNECT_HOME/logs/目录，或容器stdout日志）找完整报错，比如：

Caused by: io.debezium.jdbc.JdbcConnectionException: Error connecting to PostgreSQL database
或者
Caused by: org.postgresql.util.PSQLException: FATAL: permission denied for replication slot "debezium_slot"

根异常会直接告诉你是连接、权限还是WAL日志的问题，这是最快定位的关键。

• 连接与权限验证：
  • 用连接器配置的账号手动连接PostgreSQL：psql -h <PG_HOST> -U <CONNECT_USER> -d <TARGET_DB>，测试是否能正常登录。如果连不上，大概率是账号密码变更、数据库重启或连接池耗尽。
  • 检查账号的复制权限：执行SELECT rolname, rolreplication FROM pg_roles WHERE rolname = '<CONNECT_USER>';，确保rolreplication值为t。中途权限被回收会直接导致CDC捕获失败。
• 复制槽状态：
  执行SELECT slot_name, slot_type, active, restart_lsn FROM pg_replication_slots;，找到连接器对应的复制槽：
  • 如果active为f，说明连接器与PostgreSQL的复制连接已断开，可能是网络波动或连接器进程异常导致。
  • 对比restart_lsn和当前WAL位置pg_current_wal_lsn()，若pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn)超过wal_keep_size设置，说明WAL日志被过早清理，连接器无法同步。
• PostgreSQL日志：
  去PostgreSQL日志目录（如/var/log/postgresql/）查找FATAL: connection limit exceeded、permission denied或could not open WAL file这类错误，它们是触发连接器停止的直接原因。

• 内存与GC问题：
  若Connect的JVM内存不足，会频繁GC甚至OOM，导致连接器进程崩溃。查看日志是否有OutOfMemoryError，或用jstat -gc <CONNECT_PID>监控GC状态。如果是这个问题，需要调大Connect的KAFKA_HEAP_OPTS（比如设置为-Xms4G -Xmx4G）。
• 连接器配置合理性：
  • 检查poll.interval.ms是否过小，导致频繁拉取压垮资源；batch.size是否太大，导致单次处理数据量超过内存。
  • 确认heartbeat.interval.ms设置是否合理，若心跳间隔太长，PostgreSQL可能会把复制槽标记为失效。

• 测试PostgreSQL与Kafka Connect之间的网络稳定性：用ping <PG_HOST>持续验证，或查看系统日志（如/var/log/messages）是否有丢包、连接重置记录。
• 若为云环境，确认安全组、防火墙规则是否有临时变更，导致Connect无法访问PostgreSQL的5432端口。

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