kafka.js

import { Kafka } from 'kafkajs';

const test = process.env.TEST == "true" ? true : false;

// If test mode is true, don't send anything to kafka cluster
const kafka = new Kafka({
  brokers: [test ? "" : process.env.KAFKA_URL],
  sasl: {
    mechanism: test ? "" : process.env.KAFKA_MECHANISM,
    username: test ? "" : process.env.KAFKA_USERNAME,
    password: test ? "" : process.env.KAFKA_PASSWORD,
  },
  ssl: true,
})

// setup kafka producer
const producer = kafka.producer()

// Send a message about which word is chosen for drawing
export const sendWordMessage = async (word) => {
    await producer.connect()
    await producer.send({
        topic: 'logs',
        messages: [
            { key: "word", value: word },
        ],
    }).then(console.log).catch(e => console.error(e.message));
    await producer.disconnect()
    return true;
}

// Send number of people in room
export const sendRoomStats = async (count) => {
  await producer.connect()
  await producer.send({
      topic: 'logs',
      messages: [
          { key: "room", value: `${count}` },
      ],
  }).then(console.log).catch(e => console.error(e.message));
  await producer.disconnect()
  return true;
}