npm i kafka-node

接收消息

// 一旦提供topic立刻开始fetch消息
  const kafka = require('kafka-node')
  const client = new kafka.KafkaClient({ kafkaHost: '192.168.133.128:9092' });
  const consumer = new kafka.Consumer(client, [
    { topic: 'test', partition: 0 }
  ]);
  consumer.on('message', function (message) {
    console.log('接收一条', message.value);
  });

生产消息

var kafka = require('kafka-node'),
  Producer = kafka.Producer,
  client = new kafka.KafkaClient({kafkaHost: '192.168.133.128:9092'}),
  producer = new Producer(client);

let payloads = [{
    topic: 'test',
    messages: 'hi_from_node' + new Date(),
  }
];

producer.on('ready', function () {
  console.log('ready');
  producer.send(payloads, function (err, data) {
    console.log(err, data);
  });
});

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