用javarequest和JSR223采样器创建了Kafka的基本脚本。在脚本执行过程中出现以下错误。
示例脚本:
进口组织。Apache。Kafka。客户。生产商。Kafka生产商;
导入组织。apache。kafka。公共。序列化。字符串序列化器;
导入组织。Apache。Kafka。客户。生产者。生产者记录;
导入组织。Apache。Kafka。客户。生产者。生产者配置;
导入组织。Apache。Kafka。共同。头。头;
导入组织。Apache。Kafka。共同。头。内部。记录头;
导入组织。Apache。Kafka。共同。标题。标题;
导入组织。Apache。Kafka。共同。头。内部。记录头;
属性props =新属性();
prop .放("Zookeeper.连接","Zookeeper:2181");
props. put(" Bootstrap .服务器","b-1..亚马逊网站:9096");
props. put("键.序列化器","org. apache. kafka. common.序列化.字符串序列化器");
props. put("值.序列化器","org. apache. kafka. common.序列化.字符串序列化器");
支持放置("压缩类型","无");
prop 投放("批量"、"16384");
props.put("linger.ms", "0");
支持放置("缓冲存储器"、"33554432");
支持输出("acks"、"1");
props. put("发送.缓冲.字节","131072");
props. put("接收.缓冲.字节","32768");
props. put("安全协议","SASL SSL");
props.put("sasl.kerberos.service.name", "kafka");
支持放置("安全机制","SCRAM-SHA-512");
//System.setProperty("java.security.auth.login.config","C:/kafka/JAAS.conf");
props. put("java. security. auth. login. config","C:/Kafka/JAAS. conf");
Kafka制作人〈字符串,字符串〉制作人=新Kafka制作人〈字符串,字符串〉( prop );
错误:
[下午1:38]维拉贾,尼拉姆(合同)
2022年12月26日08:07:47,302信息o.a.k.c.p.Kafka制片人:[生成器客户端ID = JMeterKafkaBackendListener]正在关闭Kafka生成器,超时毫秒= 0毫秒。
[下午1:39]维拉贾,尼拉姆(合同)
引发原因:org. apache. kafka.常见。未能构建Kafka生产者
[下午1:40]维拉贾,尼拉姆(承包)
原因:org. apache. kafka. common. config.配置异常:bootstrap. servers中未给出可解析的引导URL
1条答案
按热度按时间ctzwtxfj1#
确保您的
b-1..amazonaws.com:9096
主机和端口组合可从JMeter负载生成器访问1.Kafka经纪人正在运行
1.端口9096在操作系统firewall中打开
1.端口9096在AWS security groups中打开
1.如果需要任何VPN或代理才能到达Kafka代理-请确保连接到VPN或让JMeter知道代理服务器
更多信息:How to Do Kafka Testing With JMeter