jmeter取样器之KafkaProducerSampler(往kafka插入数据)
项目背景
性能测试场景中有一个业务场景的数据抽取策略是直接使用kafka队列,该场景需要准备的测试数据是kafka队列里的数据,故需要实现插入数据到kafka队列,且需要实现控制每分钟插入多少条数据。
解决方案
通过研究了解到jmeter工具的kafka插件可以实现往kafka插入数据,且可以通过jmeter的固定吞吐量控制器实现每分钟插入多少条数据。
1、jmeter中下载kafka插件
jmeter界面,菜单Options>Plugins Manager,在Available页签中搜索kafka安装DI KafkaMeter和Kafka Support,由于本次已安装所以这里是显示在Installed Plugins页签里面。
2、添加配置元件KafkaProducerConfig
Kafka Brokers配置kafka的IP和端口,其他保持默认配置,无需改动。
3、添加取样器KafkaProducerSampler
配置KafkaProducerSampler,配置kafka topic和message
4、执行脚本,实现往kafka插入数据。
5、添加固定吞吐量控制器,实现每分钟插入的条数。
在kafka取样器请求下添加固定吞吐量控制器,操作步骤:Add>Timer>Constant Throughput Timer
Constant Throughput Timer控制器中Target throughput(in samples per minute)设置每分钟需要插入的条数,如此处的360则代表每分钟插入360条数据。
Calculate Throughput based on选择all active threads in current thread group
应用价值
jmeter的配置元件KafkaProducerConfig和KafkaProducerSampler可以实现往kafka队列写数据;jmeter的吞吐量控制器Constant Throughput Timer可实现每分钟插入多少数据。
最新文章
- WCF学习之旅—WCF第二个示例(七)
- SQL SERVER 9003错误解决方法 只适用于SQL2000
- 鸡和蛋的OO设计
- mysql高可用之DRBD + HEARTBEAT + MYSQL
- Struts2 中result type属性说明
- java和C#中 定义变量,加一个小括号是什么意思。。。
- listview自定义背景以及item自定义背景
- [HNOI2012] 矿场搭建
- 99%Bug 修复方法
- 关于static静态
- ORA-24324、ORA-12560、ORA-12514
- 用Jetty和redis实现接入服务器adapter
- ajax中的stasus错误详解
- 设计模式 -->; (14)中介者模式
- [Swift]LeetCode508. 出现次数最多的子树元素和 | Most Frequent Subtree Sum
- LINUX系统VMSTAT命令详解
- Technical poem
- jdk动态代理在idea的debug模式下不断刷新tostring方法
- 简单绕过Chrome密码查看逻辑,查看浏览器已保存的密码
- Java多线程知识-Callable和Future