Kafka JS consumer code

consumer.js

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

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

const consumer = kafka.consumer({ groupId: "tweets_cg_one" });

const runConsumer = async () => {
  await consumer.subscribe({
    topic: "tweets_node",
    fromBeginning: true,
  });

  await consumer.run({
    eachMessage: async ({ topic, partition, message }) => {
      console.log({
        key: message.key.toString(),
        value: message.value.toString(),
        headers: message.headers,
      });
    },
  });
};

// run the consumer
runConsumer();