使用kcat连接无认证AWS MSK集群列主题时遇连接错误

核心问题分析 #

你遇到的Disconnected while requesting ApiVersion错误，大概率是配置解析错误或端口/协议不匹配导致的，结合操作细节可从以下几点逐一排查：

1. 移除配置文件中多余的引号 #

你的kc.properties里bootstrap.servers带了双引号，这会被kcat当作Broker地址的一部分，导致无法正确解析Broker地址：

# 错误写法
bootstrap.servers="b1:9094,b2:9094"

# 正确写法
bootstrap.servers=b1:9094,b2:9094

2. 匹配MSK集群的监听器端口与协议 #

AWS MSK默认端口规则：

• 9092：PLAINTEXT无加密监听器
• 9094：SSL加密监听器

如果你的集群未配置认证，但开启的是SSL监听器（MSK默认会启用SSL），那即使无认证，也需要用security.protocol=SSL连接9094端口；如果集群开启了PLAINTEXT监听器，就用9092端口+PLAINTEXT协议。

对应配置示例 #

情况1：集群启用SSL监听器（无认证）

bootstrap.servers=b1:9094,b2:9094
security.protocol=SSL

情况2：集群启用PLAINTEXT监听器

bootstrap.servers=b1:9092,b2:9092
security.protocol=PLAINTEXT

3. 避免重复指定bootstrap.servers #

你同时用了-b参数和-F加载配置文件，可能引发配置冲突。建议只保留一种方式：

# 仅使用配置文件
kcat -F kc.properties -L

# 或直接在命令行指定参数
kcat -b b1:9092,b2:9092 -L

额外验证步骤 #

登录AWS控制台，进入你的MSK集群详情页，查看「监听器」配置，确认当前集群启用的监听器类型和端口，确保客户端配置与集群配置完全匹配。

内容的提问来源于stack exchange，提问作者erase.ego