一個使用多線程發送消息到kafka集羣的java程序

本人之前參與的某個大數據項目，由於測試的需要，所以幫助寫了一個數據發送工具用於發送大量數據到kakfa進行業務性能壓測。程序雖然簡單，但我想對於初學kafka的同學，還是有一定的借鑑意義的，遂打算貢獻出來。 本來是打算把源碼打成壓縮包上傳的，無奈公司在安全方面做的很嚴格，將文件上傳到csdn， github等網站會被公司電腦檢測到並被禁止，無奈以只能粘貼到博文中（目前已經去除與公司業務相關的任何代

>>阅读原文<<