Шаг 1. Установите библиотеку Kafka для Node.js
Откройте файл terminal в каталоге вашего Node.js проекта.
Выполните следующую команду, чтобы установить kafkajs
библиотеку, Node.js библиотеку для Apache Kafka: npm install kafkajs
.
Шаг 2. Отправка сообщений с Producer помощью Node.js
Импортируйте kafkajs
библиотеку и определите Kafka Broker конфигурацию:
Создайте producer для отправки сообщений и отправьте сообщение на topic:
Шаг 3: Получение сообщений с Consumer помощью Node.js
Импортируйте kafkajs
библиотеку и определите конфигурацию Kafka Broker(если это еще не сделано):
Создайте consumer для получения сообщений от определенного topic:
Примечание. Замените такие значения 'your-client-id'
, как 'broker1:port1'
, 'your-topic'
, и 'your-group-id'
фактической информацией о проекте.
Обязательно обратитесь к официальной документации Apache Kafka и kafkajs
библиотеке для получения дополнительной информации о параметрах конфигурации и функциях.