consumer.js

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

run();

async function run() {
    try {
        // Create an admin connection
        const kafka = new Kafka({
            "clientId": "myapp",
            "brokers": ["pmventura:9092"]
        });

        const consumer = kafka.consumer({groupId: "test"});
        console.log("Connnectingg......");
        await consumer.connect();
        console.log("Connected!");

        // Read all the time
        await consumer.subscribe({
            "topic": "Users",
            "fromBeginning": true
        });

        await consumer.run({
            // This will gonna process each message has been received
            "eachMessage": async result => {
                console.log(`RVD Msg ${result.message.value} on partition ${result.partition}`)
            }
        });

    }
    catch(ex) {
        console.error(`Something bad happened ${ex}`)
    }
    finally {

    }
}