Kafka Node - Consumer pause

nKafka.js

// consumer1.js
const kafka           = require('kafka-node');
const CONFIG          = require('../config/index');
const _TOPIC          = CONFIG.KAFKA.TOPICS.TOPIC_1;

try {
  const { Consumer }  = kafka;
  const client        = new kafka.KafkaClient(CONFIG.KAFKA.SERVER);
  const consumer      = new Consumer(
    client,
    [{ topic: _TOPIC, partition: 0 }],
    {
      autoCommit: true,
      fetchMaxWaitMs: 1000,
      fetchMaxBytes: 1024 * 1024,
      encoding: 'utf8',
      keyEncoding: 'utf8',
      fromOffset: false,
    },
  );
  consumer.on('message', async (message) => {
    console.log(`Message received at ${_TOPIC}. Message [ `, message.value, ' ]');
  });
  consumer.on('error', (err) => {
    console.log(`${_TOPIC} topic error =>`, err);
  });
} catch (e) {
  console.log(e);
}

// +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
// main.js

app.get('/api/v1/pause/:topicName', (req, res) => {
  // Need to pause the consumer from here
});