JMeter插件发送Kafka消息

JMeter直接加载一个扩展插件,可以直接发送Kafka消息

链接:https://github.com/BrightTag/kafkameter

放到JMeter_Dir/lib/ext里,重新启动jmeter之后,新增一个Java Request

NewImage

就可以发现Kafka消息发送的信息

NewImage

编辑brokers,topic,key和message即可

格式请按照约定的kafka消息格式来编辑

NewImage

最好不要在本地个人电脑上来发送kafka消息,因为既然是测试性能就别这么玩,本地网络和远程云服务网络链路肯定十分长,说不定还要连接VPN才能进行网络转发,因此直接将本地编辑好的jmx文件保存,上传到测试环境某一个测试服务器上,确保kafka消息能发出,然后服务器上命令行执行jmeter命令,比如

jmeter -n -X -t sendKafka.jmx -l result

需要注意的是,jmeter里的各种依赖包一个也不能少,和本地执行jmeter的依赖保持一致

NewImage

这里终端输出的结果,TPS恒定在500,中间三项数据为平均,最小,最大的响应时间,最后是错误率

至于TPS的指定,添加一个Throughput Timer即可,这里输入的是每分钟的数据

NewImage

查看kafka消息堆积可以通过kafka-manager,或者直接命令行指定top查看

命令可以网上搜到

./kafka-consumer-offset-checker.sh --zookeeper 10.111.0.10:8888,10.111.0.20:8888,10.111.0.30:8888 --topic LIHUI_TEST_TOPIC --group dev --broker-info

可以直接watch查看变化情况

 

最后有一点要注意的是,因为这是个两年前的插件,kafka和scala版本也比较老,小版本也有要求,具体如下

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.8.2</artifactId>
<version>0.8.0</version>
</dependency>

<dependency>
<groupId>org.scala-lang</groupId>
<artifactId>scala-library</artifactId>
<version>2.8.2</version>
</dependency>

然后可以在Consumer端收听消息

发表回复