Чтобы установить KafkaJS, вы можете использовать несколько методов в зависимости от вашей среды программирования. Вот несколько примеров:

Метод 1: использование npm (менеджера пакетов узла)

Если вы используете Node.js, вы можете установить KafkaJS с помощью npm. Откройте терминал или командную строку и выполните следующую команду:

npm install kafka-node

Метод 2: использование Yarn

Если вы предпочитаете использовать Yarn в качестве менеджера пакетов, вы можете установить KafkaJS, выполнив следующую команду:

yarn add kafka-node

Способ 3: установка вручную

Кроме того, вы можете установить KafkaJS вручную, загрузив пакет и включив его в свой проект.

1. Посетите репозиторий KafkaJS GitHub по адресу: https://github.com/tulios/kafkajs
2. Нажмите кнопку «Код» и выберите «Загрузить ZIP», чтобы загрузить пакет.
3. Извлеките загруженный ZIP-файл в выбранную вами папку.
4. Включите в свой проект библиотеку KafkaJS, ссылаясь на извлеченные файлы.

Пример кода

Вот простой пример использования KafkaJS после его установки:

const { Kafka } = require('kafkajs');
async function run() {
  const kafka = new Kafka({
    clientId: 'my-kafka-app',
    brokers: ['localhost:9092']
  });
  const producer = kafka.producer();
  await producer.connect();
  await producer.send({
    topic: 'my-topic',
    messages: [
      { value: 'Hello KafkaJS!' },
    ],
  });
  await producer.disconnect();
}
run().catch(console.error);

Этот код настраивает производителя Kafka, отправляет сообщение в тему «моя тема», а затем отключается. Обязательно замените 'localhost:9092'соответствующим адресом брокера Kafka.