Запустіть та протестуйте Kafka з Zookeeper на Windows - javascript.org.ua

Встановіть WSL.

wsl --install

Завантажте та встановіть Docker
Завантаження, налаштування та тестування Kafka і Zookeeper

Завантаження

Apache Kafka можна завантажити з офіційного сайту. натисніть тут.

Scala 2.13 — kafka2.13–3.9.0.tgz (asc, sha512)_

Налаштування: Kafka з ZooKeeper

ПРИМІТКА: У вашому локальному середовищі має бути встановлена Java 8+.

Розпакуйте завантажений файл.

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

# Запуск сервісу ZooKeeper  
$ bin/zookeeper-server-start.sh config/zookeeper.properties

Відкрийте ще одну сесію термінала та запустіть:

# Запуск сервісу Kafka broker  
$ bin/kafka-server-start.sh config/server.properties

Після того як всі сервіси успішно запустяться, у вас буде працювати базове середовище Kafka, готове до використання.

Тестування

Встановіть пакет kafkajs

npm ini -y  
npm install kafkajs

У файлі /src/kafka.js :

import { Kafka } from "kafkajs"  

export const kafka = new Kafka({  
 clientId: 'my-app',  
 brokers: ['localhost:9092'],  
})

У файлі /src/producer.js :

import { kafka } from "./kafka.js"  

const producer = kafka.producer()  

await producer.connect()  
await producer.send({  
 topic: 'test-topic',  
 messages: [  
 { value: 'Hello KafkaJS user!' },  
 ],  
})  

await producer.disconnect()

У файлі /src/consumer.js :

import { kafka } from "./kafka.js"  

const consumer = kafka.consumer({ groupId: 'test-group' })  

await consumer.connect()  
await consumer.subscribe({ topic: 'test-topic', fromBeginning: true })  

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