...
- Распакуйте архив, например в директорию D:\Programs\kafka\ . Получится, что распакованный дистрибутив лежит в D:\Programs\kafka\kafka_2.12-0.11.0.0\ . Будем считать этот путь директорией установки kafka.
- В папке config в директории установки kafka редактируем файл server.properties. Устанавливаем свойство log.dirs на путь к директории где kafka будет хранить свои данные. Например /tmp/kafka
Старт
...
- Сначала стартуем zookeeper. Из директории bin в директории установки zookeper запускаем zkServer.cmd
- Стартуем kafka. В директории bin/windows в директории установки kafka запускаем
| Блок кода |
|---|
kafka-server-start.bat ../../config/server.properties |
Проверка работы
Список топиков
В директории bin/windows в директории установки kafka запускаем
| Блок кода |
|---|
kafka-topics.bat --zookeeper localhost:2181 --list |
Публикация сообщения в топик
| Блок кода |
|---|
kafka-console-producer.bat --broker-list localhost:9092 --topic test |
Чтение сообщений из топика