Debezium连接池配置失败：启动时连接验证报错求助

问题分析 #

你遇到的启动连接拒绝错误，核心原因是Debezium的PostgreSQL连接器初始化时的连接验证逻辑未使用自定义连接工厂，而是默认通过JDBC驱动直接创建连接，跳过了你配置的Agroal数据源；同时原运行时的连接重试错误，本质是Debezium默认的连接管理未使用连接池，导致长连接失效后频繁重试。

分步解决方案 #

1. 修复自定义连接工厂的CDI管理 #

确保自定义连接工厂被Quarkus的CDI容器正确识别和注入，添加@ApplicationScoped注解：

@Startup
@ApplicationScoped
public class DebeziumConnectionPoolConfig implements JdbcConnection.ConnectionFactory {

    @Inject
    AgroalDataSource datasource;

    @Override
    public Connection connect(JdbcConfiguration jdbcConfiguration) throws SQLException {
        Connection connection = datasource.getConnection();
        // 适配Debezium CDC的连接属性要求
        connection.setAutoCommit(false);
        return connection;
    }
}

2. 调整Quarkus数据源配置（添加CDC必需参数） #

Debezium PostgreSQL连接器需要复制模式的JDBC连接，同时优化连接池参数适配长连接场景：

quarkus.datasource.db-kind=postgresql
quarkus.datasource.jdbc.url=jdbc:postgresql://localhost:5435/postgres?replication=database
quarkus.datasource.username=postgres
quarkus.datasource.password=postgres
# 适配CDC长连接的连接池配置
quarkus.datasource.jdbc.max-size=5
quarkus.datasource.jdbc.min-size=2
quarkus.datasource.jdbc.idle-timeout=30m
quarkus.datasource.jdbc.max-lifetime=1h

3. 精简Debezium配置（避免重复连接参数） #

已通过Agroal数据源提供连接信息，移除Debezium中重复的数据库连接参数，保留CDC核心配置：

# DEBEZIUM
name=my-cdc
database.connection.factory.class=org.acme.dbz.config.DebeziumConnectionPoolConfig
connector.class=io.debezium.connector.postgresql.PostgresConnector
database.dbname=postgres
# CDC核心配置
plugin.name=pgoutput
database.server.name=my-postgres-server
database.replication.slots.name=my-cdc-slot

4. 修复Debezium连接验证逻辑 #

Debezium默认的连接验证会绕过自定义连接工厂，需重写连接器的验证方法：

public class CustomPostgresConnector extends PostgresConnector {
    @Override
    protected void validateConnection(JdbcConnection jdbcConnection) throws SQLException {
        // 使用自定义连接工厂获取连接进行验证
        try (Connection conn = jdbcConnection.connection()) {
            try (Statement stmt = conn.createStatement()) {
                stmt.executeQuery("SELECT 1");
            }
        }
    }
}

然后修改Debezium配置中的连接器类：

connector.class=org.acme.dbz.config.CustomPostgresConnector

5. 基础连接排查（若仍出现连接拒绝） #

• 确认PostgreSQL的postgresql.conf中listen_addresses='*'，允许TCP/IP连接
• 确认pg_hba.conf添加本地连接规则：host all postgres 127.0.0.1/32 scram-sha-256
• 检查端口映射（容器环境）或防火墙规则，确保Quarkus应用能访问5435端口

原运行时连接重试错误的解决逻辑 #

当连接池配置生效后，Agroal会自动维护连接的存活状态，回收失效连接并创建新连接，避免Debezium因原生连接管理的缺陷导致的频繁重试问题，稳定供给CDC所需的长连接。

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