Правильный способ чтения сообщений из темы Kafka и последующего закрытия

Я создаю простой API-интерфейс node.js, используя экспресс-узел и узел kafka, который возвращает непрочитанные сообщения из запрошенной темы Kafka и группы потребителей при получении HTTP-запроса, а затем закрывает соединение. Мне не нужно или я не хочу, чтобы потребитель продолжал ждать новых сообщений.

В kafka-node, как правильно проверить, достигнут ли конец темы, и если да, закрыть соединение с брокером и выйти из приложения, чтобы предотвратить чтение новых сообщений?

Вот мой потребитель.js. Это почти то же самое, что и пример, приведенный в документации kafka-node.

"use strict";

const kafka = require("kafka-node");

let topicName = "testTopic-01",
  groupName = "testGroup-01",
  consumerOptions = {
    kafkaHost: "localhost: 9092",
    groupId: groupName,
    sessionTimeout: 15000,
    protocol: ["roundrobin"],
    fromOffset: "earliest",
    encoding: "utf8"
  };

const consumerGroup = new kafka.ConsumerGroup(consumerOptions, topicName);

consumerGroup.on("message", message => {
  console.info(`Message: ${message.value}`);
});
consumerGroup.on("error", error => {
  console.error(error);
});

console.info(`Consumer started on topic ${topicName} on group ${groupName}`);