kafkaproducer.jar

用法如下：

查看参数
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

源代码