throttle5.js

const async = require('async');
const { ConsumerGroup } = require('kafka-node');

const consumerConfig = {
    kafkaHost: 'broker:9092',
    groupId: 'order-service',
    fetchMaxBytes: 100 * 1024, // 100 KB
    autoCommit: false,
};

const consumer = new ConsumerGroup(consumerConfig, 'OrderTopic');

async function processData(queueData) {
    // perform data processing here
}

const concurrency = 5;
const q = async.queue(processData, concurrency);

consumer.on('message', (data) => {
    consumer.pause();
    q.push(data);
});