throttle2.js

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

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

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

consumer.on('message', (data) => {
    // queue data available here
});