Confluent Cloud远程连接本地MySQL连接器失败求助

核心排查方向 #

本地JDBC能正常连接但Confluent Cloud远程连接器失败，问题基本出在公网到本地MySQL的网络可达性或MySQL远程访问的细节配置，以下是针对性解决步骤：

1. 修正网络访问配置（最关键）

   • 本地MySQL处于私有局域网（192.168.x.x），Confluent Cloud无法直接访问内网IP，必须：
     • 在路由器上开启3306端口的端口转发，将公网3306端口指向本地笔记本的内网IP（192.168.2**.2**）
     • 连接器配置的connection.host必须填写你的公网IP，而非内网IP
   • 验证公网可达性：用另一台非局域网设备执行telnet 你的公网IP 3306，确认3306端口是否对外开放

2. 调整MySQL绑定地址

   • 修改MySQL主配置文件（my.cnf/my.ini）中的bind-address参数为0.0.0.0（允许所有IP访问），而非仅绑定Confluent IP
   • 执行SQL语句确认生效：

     SHOW VARIABLES LIKE 'bind_address';
     

   • 重启MySQL服务使配置生效

3. 修正MySQL用户权限

   • Confluent Cloud的连接器出口IP可能不固定，之前绑定单一Confluent IP的用户权限会失效，创建允许全网访问的用户：

     CREATE USER 'Adhi'@'%' IDENTIFIED BY '你的密码';
     GRANT ALL PRIVILEGES ON test_kafka_connectors.* TO 'Adhi'@'%';
     FLUSH PRIVILEGES;
     

   • 验证用户配置：

     SELECT user, host FROM mysql.user WHERE user='Adhi';
     

     确保host字段为%（允许所有IP）或包含Confluent实际出口IP

4. 排除SSL配置干扰

   • 若本地MySQL未开启SSL，连接器设置ssl.mode=prefer可能触发连接失败，先尝试将ssl.mode改为disabled测试连接，确认是否为SSL问题

5. 检查连接器参数细节

   • 若连接器支持直接填写connection.url，用完整JDBC URL配置，避免拆分参数出错：

     jdbc:mysql://你的公网IP:3306/test_kafka_connectors?useSSL=false&serverTimezone=UTC
     

   • 若密码包含特殊字符（如@、&、=），需进行URL编码后再填入配置（例如@编码为%40）

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