Kafka JDBC Sink连接器未读取正确配置 连接localhost:5432被拒

核心根因 #

你当前故障的直接诱因是JDBC连接URL格式不符合PostgreSQL驱动规范。
你配置的连接地址为：
jdbc:postgresql:192.168.128.2:5432/postgres
PostgreSQL JDBC驱动要求主机地址段前必须加//标识，缺少该标识时驱动不会解析后续填写的主机、端口参数，会直接使用默认值localhost:5432发起连接，这就是你多次修改主机地址为容器IP、host.docker.internal仍固定报localhost连接拒绝的原因。

修复步骤 #

1. 修正JDBC连接URL格式 #

将连接器配置中的connection.url替换为标准格式：

"connection.url": "jdbc:postgresql://<副本PostgreSQL可达地址>:5432/postgres"

注意：地址必须是Kafka Connect运行环境内可正常访问的地址，不要直接填localhost——Kafka Connect如果运行在容器中，localhost指向容器自身，不是宿主机或其他容器。

2. 提前校验网络连通性 #

不要直接重启连接器碰运气，先进入Kafka Connect容器验证端口连通性：

# 进入Kafka Connect容器
docker exec -it -u root <kafka-connect容器ID> /bin/bash
# 安装网络测试工具（Debian/Ubuntu基础镜像用apt，RHEL用yum）
apt update && apt install -y netcat-openbsd
# 测试副本库5432端口连通性
nc -zv <副本PostgreSQL地址> 5432

如果端口不通，按部署场景逐一排查：

• 副本库为独立启动的Docker容器：确认启动时添加了-p 5432:5432端口映射参数；进入副本库容器检查postgresql.conf中listen_addresses = '*'，pg_hba.conf中放行了Kafka Connect所在网段的连接权限
• 副本库已接入原有Docker Compose网络：直接使用副本库在Compose中的服务名作为连接地址即可，不需要查容器IP，也不需要配置端口映射，例如副本库服务名为replica-pg，连接地址就写jdbc:postgresql://replica-pg:5432/postgres，容器内网直接互通
• Linux环境下Docker默认不支持host.docker.internal域名，需要在启动Kafka Connect容器时添加--add-host=host.docker.internal:host-gateway参数才能使用，树莓派ARM架构下该参数兼容性不稳定，优先使用容器服务名、容器IP或宿主机物理网卡IP连接

3. 校验插件与配置有效性 #

1. 确认JDBC Sink插件已被正常加载：

   curl http://localhost:8083/connector-plugins | grep JdbcSinkConnector
   

   正常返回io.confluent.connect.jdbc.JdbcSinkConnector才说明插件加载成功，如果没有返回，检查插件目录权限、插件包完整性，确认插件目录是/kafka/connect/下的独立子目录，所有jar包在子目录内而非散放在根路径。
2. 修正配置后重新提交连接器，等待10秒后查询任务状态，如果仍报错，直接拉取Kafka Connect运行日志看完整错误栈，不要只看status接口的简略报错：

   docker logs <kafka-connect容器ID> --tail 200
   

常见避坑点 #

• 全新启动的PostgreSQL容器要确认初始化时设置的账号密码和连接器配置中connection.user、connection.password一致，避免密码错误导致连接失败
• 10.5.0版本的Confluent JDBC连接器自带的PostgreSQL驱动可兼容PostgreSQL 10-13版本，如果你的副本库是14及以上大版本，建议替换插件目录下的PostgreSQL JDBC驱动为对应大版本，避免协议兼容问题
• 不要在配置了auto.create=true的情况下提前手动建表，自动建表的字段类型映射和手动建表可能存在差异，容易触发写入报错

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