JMeter开展Kafka负载测试时遇连接超时及Bootstrap地址解析异常

1. 修复bootstrap.servers地址 #

你当前配置的bootstrap.servers值"b-1..amazonaws.com:9096"存在格式错误（多了一个冗余点），属于无效地址。需要替换为Kafka集群提供的完整正确Broker地址，格式示例：

props.put("bootstrap.servers", "b-1.your-cluster-name.xxxxxx.amazonaws.com:9096,b-2.your-cluster-name.xxxxxx.amazonaws.com:9096");

建议配置多个Broker地址做冗余，避免单点故障。

2. 验证地址网络可达性 #

在运行JMeter的机器上，测试能否连通Broker地址：

• Windows系统执行：telnet b-1.your-cluster-name.xxxxxx.amazonaws.com 9096
• Linux/macOS系统执行：nc -zv b-1.your-cluster-name.xxxxxx.amazonaws.com 9096
  如果无法连通，需检查网络防火墙、AWS安全组是否开放9096端口，确保JMeter机器能访问Kafka集群。

3. 修正JAAS配置的设置方式 #

java.security.auth.login.config是JVM系统属性，不是Kafka生产者的配置参数，不能通过props.put()设置，必须改用System.setProperty()。把脚本中的：

props.put("java.security.auth.login.config", "C:/kafka/JAAS.conf");

替换为：

System.setProperty("java.security.auth.login.config", "C:/kafka/JAAS.conf");

同时确保JAAS文件内容符合SCRAM-SHA-512格式，示例：

KafkaClient {
    org.apache.kafka.common.security.scram.ScramLoginModule required
    username="你的SCRAM用户名"
    password="你的SCRAM密码";
};

4. 移除无用配置 #

新版Kafka生产者无需zookeeper.connect配置（生产者直接通过bootstrap.servers连接Broker），可以删除这一行代码：

props.put("zookeeper.connect", "Zookeper:2181");

5. 检查客户端版本兼容性 #

确保你使用的Kafka客户端Jar包版本与目标集群版本兼容（建议版本差不超过1个大版本），版本不兼容也可能引发地址解析或连接失败问题。

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