日常工作中有時候需要向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