因为需要测试风控决策引擎，需要使用JMeter往Kafka中灌入数据，但是如果手动一条条json进去那就累死个人，解决方法就是通过JMeter发送数据到kafka并进行消费，废话不多说，看下面流程

1. 首先在下载jmeter到本地，在lib-》ext目录中导入一个kafkameter.jar包，如下图：
   

jar包下载地址：https://download.csdn.net/download/hui_yong/84834292

2. 插入jar之后，打开JMeter进行操作了，首先新建一个Thread group，在线程组下面添加一个Java request：
   

3. 在Java request中Class name选择下拉列表，这就是你导入到ext目录中的jar，配置Kafka参数如下图（找你们开发要）：
   

发送消息：

服务端消费者，这里怎么监听消息，需要进入服务端命令如下：

填写上面的配置参数后，先在服务端开启kafka消费者这，如果jmeter发送消息后，服务端能正常消费证明配置是没问题了。

4. 最后就是线程组并发数，这里需要根据你们项目要求定义并发量：