使用Golang连接带SCRAM认证的AWS MSK遇IO超时问题

首先明确：你遇到的i/o超时错误和SCRAM认证配置无关，因为连接还没建立到需要验证身份的阶段，核心问题是网络层面无法访问目标地址。

错误根源 #

1. 端口使用错误：你代码里连的2182是AWS MSK的ZooKeeper端口，这个端口默认仅允许集群所在VPC内部的资源访问。如果你的Golang代码运行在VPC外部（比如本地机器、其他云的服务器），哪怕VPC开了出入规则，也无法直接访问这个私有端口。而且Kafka客户端正常应该连接Broker服务端口，而非ZooKeeper端口。
2. 网络可达性问题：错误里的172.x.x.x是私有IP，说明域名解析到了MSK集群的内部地址，外部网络无法直接路由到这个IP段。哪怕VPC允许所有出入，外部机器也没有访问VPC私有IP的权限，除非通过VPN、Direct Connect或者MSK的公网访问配置来打通网络。

解决步骤 #

• 更换连接目标：放弃连接ZooKeeper的2182端口，改用MSK集群的Broker地址和正确端口。启用SCRAM认证的MSK集群，通常使用9094作为SASL_SSL端口，你可以在AWS控制台的MSK集群详情里找到Broker的公网/内网地址。
• 打通网络通路：
  • 如果代码运行在VPC外部：在AWS控制台开启MSK集群的公网访问选项，同时配置集群安全组允许你的客户端IP访问9094端口。
  • 如果代码运行在VPC内部：确认客户端所在实例的安全组和MSK集群的安全组之间有访问9094端口的规则。
• 调整代码的连接逻辑：确保是连接Broker地址，而不是ZooKeeper地址，示例代码应该指向类似b-1.<cluster-name>.<extra-info>.us-east-2.amazonaws.com:9094这样的地址。

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