{{:wiki:kafkaproducer.jar|}}

用法如下：
<code>

查看参数
fangqiang$ java -cp KafkaProducer.jar Main  
param 1:broker list
param 2:topic name
param 3:input file path
param 4:is loop?(y/n)
param 5:interval between two message


具体使用
java -cp KafkaProducer.jar Main  master:9092 fang_topic /home/xxx y 10
</code>


===== 源代码 =====
https://github.com/fangqiang/JavaProject