'use strict'

'use strict'

const kafka = require('kafka-node')
const Producer = kafka.Producer
const producerClient = new kafka.Client()
const client = new Producer(producerClient);

client.on('ready', function () {
  console.log('Kafka producer is ready.')
});

client.on('error', function (err) {
  console.error(`\n${timestamp()} - ${err.toString()}`, `\n${err.stack}`)
})

exports.client = client

Add kafka producer service