因为需要测试风控决策引擎,需要使用JMeter往Kafka中灌入数据,但是如果手动一条条json进去那就累死个人,解决方法就是通过JMeter发送数据到kafka并进行消费,废话不多说,看下面流程
- 首先在下载jmeter到本地,在lib-》ext目录中导入一个kafkameter.jar包,如下图:
jar包下载地址:https://download.csdn.net/download/hui_yong/84834292
插入jar之后,打开JMeter进行操作了,首先新建一个Thread group,在线程组下面添加一个Java request:
在Java request中Class name选择下拉列表,这就是你导入到ext目录中的jar,配置Kafka参数如下图(找你们开发要):
发送消息:
服务端消费者,这里怎么监听消息,需要进入服务端命令如下:
填写上面的配置参数后,先在服务端开启kafka消费者这,如果jmeter发送消息后,服务端能正常消费证明配置是没问题了。
- 最后就是线程组并发数,这里需要根据你们项目要求定义并发量:



