kafkaUtil.js

'use strict'
const kafka = require('kafka-node')
const client = new kafka.Client('kafka_broker:2181')
const HighLevelProducer = kafka.HighLevelProducer
const producer = new HighLevelProducer(client)
let prodRdy = false

producer.on('ready', () => {
  producer.createTopics(['test'], false, function (err, data) {
    if (!err) {
      console.log('producer connected and ready\ncreated "test" topic')
      prodRdy = true
    } else {
      console.error(err)
    }
  })
})

exports.send = (messages, callback) => {
  const payloads = [ { topic: 'test', messages: messages } ]
  if (prodRdy) {
    producer.send(payloads, (err, data) => {
      callback(err, data)
    })
  } else {
    callback('producer not ready', null)
  }
}