因为需要测试风控决策引擎，需要使用JMeter往Kafka中灌入数据，但是如果手动一条条json进去那就累死个人，解决方法就是通过JMeter发送数据到kafka并进行消费，废话不多说，看下面流程首先在下载jmeter到本地，在lib-》ext目录中导入一个kafkameter.jar包，如下图：jar包下载地址：https://download.csdn.net/download/hui_yon

#!/usr/bin/env python#coding:utf-8import threadingimport Queueimport time  import randomdef produce(name,que):    while True:        if que.qsize()            que.put('baozi')