messageProducer.ts

import { Producer } from 'kafka-node'
import { getMessageProducer } from './message'

export function produceMessage() {
  const _that = this;
  let producer = getMessageProducer();
  let topicName = 'message-chinguyen';
  let produceTopic = topicName;

  let payloads: {
    topic: any;
    messages: any;
    key: any;
    attributes: any;
    timestamp: any;
  }[] = [];
  let curTimestamp = Date.now();
  payloads.push({ topic: produceTopic, messages: 'hahahahaha', key: 1, attributes: 'haha', timestamp: curTimestamp });

  if (payloads.length > 0) {
    producer.send(payloads, function(err, data) {
      if (err) {
        console.log("error");
      }
      else {
        console.log("success");

      }
    });
  }


}