throttle4.js

const { ConsumerGroup } = require('kafka-node');
const options = {
    kafkaHost: 'broker:9092',
    groupId: 'order-service',
    fetchMaxBytes: 100 * 1024, // 100 KB
    autoCommit: false,
};
const consumer = new ConsumerGroup(options, 'OrderTopic');
consumer.on('message', (data) => {
    consumer.pause();
    // queue data available here
});