Установка kafka windows

1. Качаем дистрибутив сайта https://kafka.apache.org/downloads
2. помещаем в папку c:\\
3. В папке C:\kafka\config в файле server меняем строчки

log.dirs=/tmp/kafka-logs
=>
log.dirs=c:/kafka/kafka-logs

4. В папке C:\kafka\config в файле zookeeper меняем строчки

dataDir=/tmp/zookeeper
=>
dataDir=c://kafka/zookeeper-data

5. Запускаем консоль CMD

cd C:\kafka

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

Запускаем еще одну консоль CMD

cd C:\kafka

.\bin\windows\kafka-server-start.bat .\config\server.properties

.\bin\windows\kafka-server-stop.bat .\config\server.properties
.\bin\windows\zookeeper-server-stop.bat .\config\zookeeper.properties

6. Чтобы создать новый topic переходим в C:\kafka\bin\windows и запускаем cmd

kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test

7. чтобы запустить producer

 kafka-console-producer.bat --broker-list localhost:9092 --topic test

8. чтобы запустить consumer

kafka-console-consumer.bat --topic test --bootstrap-server localhost:9092 --from-beginning