Дистрибутивы
Необходимо скачать targzip архивы:
- Zookeeper - D:\Programs\kafka\kafka_2.12-0.11.0.0\config\server.properties
- Kafka - версия 0.11.0.0 со страницы https://kafka.apache.org/downloads
Настройка
Zookeper
- Распакуйте архив, например в директорию D:\Programs\zookeeper\ . Получится, что распакованный дистрибутив лежит в D:\Programs\zookeeper\zookeeper-3.4.14 . Будем считать этот путь директорией установки zookeeper.
- В папке conf в директории установки zookeeper переименовываем файл zoo_sample.cfg в zoo.cfg
- В файле zoo.cfg в настройке dataDir устанавливаем путь к директории, где zookeper будет хранить свои данные в unix формате. Например /tmp/zookeeper
Kafka
- Распакуйте архив, например в директорию 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
Чтение сообщений из топика