...

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

Тема в разделе "Вопросы по платформе", создана пользователем sinitsinav, 28 фев 2025.

  1. sinitsinav

    sinitsinav Новичок

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

    Код:
    
    await consumer.run({
        
    eachMessageasync ({ topicpartitionmessage }) => {
          
    console.log({
            
    partition,
            
    offsetmessage.offset,
            
    valuemessage.value.toString(),
          })
        },
    })
    Определение функции не отрабатывает в скрипте метода API.
    Сталкивались ли с подобной проблемой и какие варианты ее решения можете предложить?

    Спасибо!
  2. panov

    panov Новичок

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