NodeJS kafka 测试写工具

const kafka = require(‘kafka-node’);

let conn = {‘kafkaHost’:’127.0.0.1:9092′}; //这里改IP端口

var MQ = function (){
this.mq_producers = {};
}

MQ.prototype.AddProducer = function (conn, handler){
let client = new kafka.KafkaClient(conn);
let producer = new kafka.Producer(client);

producer.on('ready', function(){
    if(!!handler){
        handler(producer);
    }
});

producer.on('error', function(err){
    console.error('producer error ',err.stack);
});

this.mq_producers['common'] = producer;
return producer;

}
console.log(MQ);
var mq = new MQ();

mq.AddProducer(conn, function (producer){
producer.createTopics([‘my-topic’], function (){
setInterval(function(){
mq.mq_producers[‘common’].send([{topic:[‘my-topic’], //这里修改topic
messages:[JSON.stringify({“cmd”:”testRpc”,”value”:”Hello World”})]}], function (){
console.log(“….. “);
})
}, 2000);
})
});