Kafka JS producer code

producer.js

const { Kafka } = require("kafkajs");

const { CompressionTypes, CompressionCodecs } = require("kafkajs");
const LZ4Codec = require("kafkajs-lz4");

CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;

var Twitter = require("node-tweet-stream"),
  t = new Twitter({
    consumer_key: "xxxx",
    consumer_secret: "xxxx",
    token: "xxxx",
    token_secret: "xxxx",
  });

const kafka = new Kafka({
  clientId: "kafka-tweets",
  brokers: ["localhost:9092"],
});

const producer = kafka.producer();

t.on("tweet", async function (tweet) {
  // Kafka producer
  await producer.connect();

  // write tweet to producer
  try {
    await producer.send({
      topic: "tweets_node",
      messages: [{ key: "tweets", value: JSON.stringify(tweet) }],
      acks: -1,
      compression: CompressionTypes.LZ4,
    });
  } catch (error) {
    console.log(error);
  }

  console.log("tweet received");
});

t.on("error", function (err) {
  console.log("Oh no", err);
});

t.track("covid");