kafka-consumer-npm

1.0.8 • Public • Published

kafka-consumer-npm

This is a basic package to consume messages from kafka topic.

NPM

Install

npm install --save kafka-consumer-npm

API

How to use

const kafkaConsumer = require("kafka-consumer-npm"); 
async function main() {

    kafkaConsumer.configure({
        brokers: ["localhost:9092"],
        saslUser: undefined,
        saslPass: undefined,
        consumerGroup: "test-consumer-group",
        topics: ["TestTopicBySarita"],
        autoCommit: true,
        allowAutoTopicCreation: false,
        readUncommitted: false,
        fromBeginning: true
    });
    
    await kafkaConsumer.initKafkaConsumer(function(topic, offset, partition, message){
        console.log({
    
            topic: topic,
            partition: partition,
            offset: offset,
            value: message,
          })
    });
    
    await kafkaConsumer.isReady();
    }
    
    main();

Dependencies (1)

Dev Dependencies (0)

    Package Sidebar

    Install

    npm i kafka-consumer-npm

    Weekly Downloads

    1

    Version

    1.0.8

    License

    MIT

    Unpacked Size

    5.61 kB

    Total Files

    5

    Last publish

    Collaborators

    • saritasingh