日常工作中有时候需要向kafka中发送消息来测试功能或者性能，这时候我们怎么办呢？我之前是自己写个简单的python脚本来模拟发送消息的，其实用Jmeter来实现也比较简单方便。
1、我们必须有kafka相关的jar包。
我是直接下载的相关jar包，链接：https://pan.baidu.com/s/1b38x-Ikl8bA3WK1EpBS-gQ，提取码：6sel
自己手动打jar包其实也很简单，参考文章：https://blog.csdn.net/masound/article/details/85101101
2、将jar包存放到apache-jmeter-5.1.1/ib/ext目录下，重启jmeter
3、向kafka推送消息
在线程下面添加“java请求”如下，填写正确的kafka地址、主题和消息内容。
如果要指定消息发送到某一个partition上也是可以的，只要正确设置下kafka_partition的值就可以了。
添加好之后运行下，即可看到kafka中新增了刚发送的数据。
备注：我在使用的时候出现了内存溢出的问题，如下：
解决可参考文章：https://www.cnblogs.com/ailiailan/archive/2019/09/21/11562367.html