Чтение топика Kafka с использованием npm-модуля kafkajs

Добрый день,
Подключили в модуль ELMA365 версии On-Premises 2024.4.61 npm-модуль kafkajs.
Коннект из скрипа к Kafka успешный, запись в топик - успешно.
Но чтение из топика не отрабатывает:

Код:

await consumer.run({
    eachMessage: async ({ topic, partition, message }) => {
      console.log({
        partition,
        offset: message.offset,
        value: message.value.toString(),
      })
    },
})

Определение функции не отрабатывает в скрипте метода API.
Сталкивались ли с подобной проблемой и какие варианты ее решения можете предложить?

Спасибо!

Добрый день!
Уведомляем Вас, что Npm-модуль kafkajs является сторонним сервисом и технически нами не поддерживается.
Рекомендуем обновить приложение Elma365 для наилучшей работоспособности системы и ознакомиться с Consumers API для Kafka: https://kafka.apache.org/documentation.html#consumerapi